[INFO] fetching crate kincir 0.2.0... [INFO] testing kincir-0.2.0 against 1.90.0 for beta-1.91-3 [INFO] extracting crate kincir 0.2.0 into /workspace/builds/worker-2-tc1/source [INFO] started tweaking crates.io crate kincir 0.2.0 [INFO] removed 0 missing tests [INFO] finished tweaking crates.io crate kincir 0.2.0 [INFO] tweaked toml for crates.io crate kincir 0.2.0 written to /workspace/builds/worker-2-tc1/source/Cargo.toml [INFO] validating manifest of crates.io crate kincir 0.2.0 on toolchain 1.90.0 [INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+1.90.0" "metadata" "--manifest-path" "Cargo.toml" "--no-deps", kill_on_drop: false }` [INFO] crate crates.io crate kincir 0.2.0 already has a lockfile, it will not be regenerated [INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+1.90.0" "fetch" "--manifest-path" "Cargo.toml", kill_on_drop: false }` [INFO] [stderr] Updating crates.io index [INFO] [stderr] Downloading crates ... [INFO] [stderr] Downloaded reactor-trait v1.1.0 [INFO] [stderr] Downloaded async-reactor-trait v1.1.0 [INFO] [stderr] Downloaded pinky-swear v6.2.0 [INFO] [stderr] Downloaded executor-trait v2.1.2 [INFO] [stderr] Downloaded redox_syscall v0.5.15 [INFO] [stderr] Downloaded tokio-executor-trait v2.1.3 [INFO] [stderr] Downloaded tokio-reactor-trait v1.1.0 [INFO] [stderr] Downloaded tokio-amqp v2.0.0 [INFO] [stderr] Downloaded rustls-connector v0.20.2 [INFO] [stderr] Downloaded amq-protocol-types v7.2.3 [INFO] [stderr] Downloaded async-global-executor-trait v2.2.0 [INFO] [stderr] Downloaded p12-keystore v0.1.5 [INFO] [stderr] Downloaded flagset v0.4.7 [INFO] [stderr] Downloaded tcp-stream v0.28.0 [INFO] [stderr] Downloaded rc2 v0.8.1 [INFO] [stderr] Downloaded clap v4.5.41 [INFO] [stderr] Downloaded pkcs12 v0.1.0 [INFO] [stderr] Downloaded des v0.8.1 [INFO] [stderr] Downloaded x509-cert v0.2.5 [INFO] [stderr] Downloaded rumqttc v0.24.0 [INFO] [stderr] Downloaded clap_builder v4.5.41 [INFO] [stderr] Downloaded lapin v2.5.4 [INFO] [stderr] Downloaded cms v0.2.3 [INFO] [stderr] Downloaded async-io v2.5.0 [INFO] [stderr] Downloaded amq-protocol v7.2.3 [INFO] [stderr] Downloaded rdkafka v0.36.2 [INFO] [stderr] Downloaded polling v3.9.0 [INFO] [stderr] Downloaded der_derive v0.7.3 [INFO] [stderr] Downloaded amq-protocol-tcp v7.2.3 [INFO] [stderr] Downloaded async-executor v1.13.2 [INFO] [stderr] Downloaded async-global-executor v3.1.0 [INFO] [stderr] Downloaded amq-protocol-uri v7.2.3 [INFO] [stderr] Downloaded rdkafka-sys v4.9.0+2.10.0 [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-2-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-2-tc1/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:e90291280db7d1fac5b66fc6dad9f9662629e7365a55743daf9bdf73ebc4ea79" "/opt/rustwide/cargo-home/bin/cargo" "+1.90.0" "metadata" "--no-deps" "--format-version=1", kill_on_drop: false }` [INFO] [stdout] d7fa59b66bdad5e618c5bce34efc6d0b127c9634466026da4a6afc34e2a42dfe [INFO] running `Command { std: "docker" "start" "-a" "d7fa59b66bdad5e618c5bce34efc6d0b127c9634466026da4a6afc34e2a42dfe", kill_on_drop: false }` [INFO] running `Command { std: "docker" "inspect" "d7fa59b66bdad5e618c5bce34efc6d0b127c9634466026da4a6afc34e2a42dfe", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "d7fa59b66bdad5e618c5bce34efc6d0b127c9634466026da4a6afc34e2a42dfe", kill_on_drop: false }` [INFO] [stdout] d7fa59b66bdad5e618c5bce34efc6d0b127c9634466026da4a6afc34e2a42dfe [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-2-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-2-tc1/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=warn" "-e" "RUSTDOCFLAGS=--cap-lints=warn" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:e90291280db7d1fac5b66fc6dad9f9662629e7365a55743daf9bdf73ebc4ea79" "/opt/rustwide/cargo-home/bin/cargo" "+1.90.0" "build" "--frozen" "--message-format=json", kill_on_drop: false }` [INFO] [stdout] 473eb46a20e9979fc09c9161856720b656f3dedd3268331a85a02cf90427f55a [INFO] running `Command { std: "docker" "start" "-a" "473eb46a20e9979fc09c9161856720b656f3dedd3268331a85a02cf90427f55a", kill_on_drop: false }` [INFO] [stderr] Compiling generic-array v0.14.7 [INFO] [stderr] Compiling cc v1.2.30 [INFO] [stderr] Compiling futures-io v0.3.31 [INFO] [stderr] Compiling crossbeam-utils v0.8.21 [INFO] [stderr] Compiling displaydoc v0.2.5 [INFO] [stderr] Compiling num-traits v0.2.19 [INFO] [stderr] Compiling nom v7.1.3 [INFO] [stderr] Compiling getrandom v0.2.16 [INFO] [stderr] Compiling base64ct v1.8.0 [INFO] [stderr] Compiling der_derive v0.7.3 [INFO] [stderr] Compiling pem-rfc7468 v0.7.0 [INFO] [stderr] Compiling concurrent-queue v2.5.0 [INFO] [stderr] Compiling const-oid v0.9.6 [INFO] [stderr] Compiling crypto-common v0.1.6 [INFO] [stderr] Compiling block-padding v0.3.3 [INFO] [stderr] Compiling inout v0.1.4 [INFO] [stderr] Compiling block-buffer v0.10.4 [INFO] [stderr] Compiling tinystr v0.8.1 [INFO] [stderr] Compiling digest v0.10.7 [INFO] [stderr] Compiling cipher v0.4.4 [INFO] [stderr] Compiling flagset v0.4.7 [INFO] [stderr] Compiling icu_locale_core v2.0.0 [INFO] [stderr] Compiling zerotrie v0.2.2 [INFO] [stderr] Compiling parking_lot_core v0.9.11 [INFO] [stderr] Compiling thiserror-impl v2.0.12 [INFO] [stderr] Compiling zerocopy v0.8.26 [INFO] [stderr] Compiling parking_lot v0.12.4 [INFO] [stderr] Compiling icu_collections v2.0.0 [INFO] [stderr] Compiling ring v0.17.14 [INFO] [stderr] Compiling rusticata-macros v4.1.0 [INFO] [stderr] Compiling getrandom v0.3.3 [INFO] [stderr] Compiling asn1-rs-derive v0.6.0 [INFO] [stderr] Compiling asn1-rs-impl v0.2.0 [INFO] [stderr] Compiling der v0.7.10 [INFO] [stderr] Compiling icu_provider v2.0.0 [INFO] [stderr] Compiling futures-sink v0.3.31 [INFO] [stderr] Compiling num-integer v0.1.46 [INFO] [stderr] Compiling hmac v0.12.1 [INFO] [stderr] Compiling event-listener v5.4.0 [INFO] [stderr] Compiling oid-registry v0.8.1 [INFO] [stderr] Compiling pbkdf2 v0.12.2 [INFO] [stderr] Compiling num-bigint v0.4.6 [INFO] [stderr] Compiling thiserror v2.0.12 [INFO] [stderr] Compiling asn1-rs v0.7.1 [INFO] [stderr] Compiling event-listener-strategy v0.5.4 [INFO] [stderr] Compiling icu_properties v2.0.1 [INFO] [stderr] Compiling icu_normalizer v2.0.0 [INFO] [stderr] Compiling rand_core v0.9.3 [INFO] [stderr] Compiling sha2 v0.10.9 [INFO] [stderr] Compiling spki v0.7.3 [INFO] [stderr] Compiling salsa20 v0.10.2 [INFO] [stderr] Compiling x509-cert v0.2.5 [INFO] [stderr] Compiling rustls-pemfile v2.2.0 [INFO] [stderr] Compiling async-trait v0.1.88 [INFO] [stderr] Compiling tokio-macros v2.5.0 [INFO] [stderr] Compiling ppv-lite86 v0.2.21 [INFO] [stderr] Compiling signal-hook-registry v1.4.5 [INFO] [stderr] Compiling rustls v0.23.29 [INFO] [stderr] Compiling rustix v1.0.8 [INFO] [stderr] Compiling tokio v1.46.1 [INFO] [stderr] Compiling rustls-native-certs v0.7.3 [INFO] [stderr] Compiling serde_json v1.0.141 [INFO] [stderr] Compiling rand_chacha v0.9.0 [INFO] [stderr] Compiling der-parser v10.0.0 [INFO] [stderr] Compiling idna_adapter v1.2.1 [INFO] [stderr] Compiling scrypt v0.11.0 [INFO] [stderr] Compiling futures-lite v2.6.0 [INFO] [stderr] Compiling aes v0.8.4 [INFO] [stderr] Compiling cms v0.2.3 [INFO] [stderr] Compiling cbc v0.1.2 [INFO] [stderr] Compiling linux-raw-sys v0.9.4 [INFO] [stderr] Compiling rustls-webpki v0.103.4 [INFO] [stderr] Compiling hashbrown v0.15.4 [INFO] [stderr] Compiling bitflags v2.9.1 [INFO] [stderr] Compiling x509-parser v0.17.0 [INFO] [stderr] Compiling pkcs12 v0.1.0 [INFO] [stderr] Compiling indexmap v2.10.0 [INFO] [stderr] Compiling pkcs5 v0.7.1 [INFO] [stderr] Compiling idna v1.0.3 [INFO] [stderr] Compiling rand v0.9.2 [INFO] [stderr] Compiling sha1 v0.10.6 [INFO] [stderr] Compiling rc2 v0.8.1 [INFO] [stderr] Compiling des v0.8.1 [INFO] [stderr] Compiling tracing-attributes v0.1.30 [INFO] [stderr] Compiling polling v2.8.0 [INFO] [stderr] Compiling cookie-factory v0.3.3 [INFO] [stderr] Compiling winnow v0.7.12 [INFO] [stderr] Compiling toml_datetime v0.6.11 [INFO] [stderr] Compiling rustix v0.37.28 [INFO] [stderr] Compiling amq-protocol-types v7.2.3 [INFO] [stderr] Compiling libz-sys v1.1.22 [INFO] [stderr] Compiling p12-keystore v0.1.5 [INFO] [stderr] Compiling tracing v0.1.41 [INFO] [stderr] Compiling piper v0.2.4 [INFO] [stderr] Compiling url v2.5.4 [INFO] [stderr] Compiling io-lifetimes v1.0.11 [INFO] [stderr] Compiling async-lock v3.4.0 [INFO] [stderr] Compiling async-channel v2.5.0 [INFO] [stderr] Compiling futures-channel v0.3.31 [INFO] [stderr] Compiling spin v0.9.8 [INFO] [stderr] Compiling futures-macro v0.3.31 [INFO] [stderr] Compiling async-io v1.13.0 [INFO] [stderr] Compiling fastrand v1.9.0 [INFO] [stderr] Compiling toml_edit v0.22.27 [INFO] [stderr] Compiling waker-fn v1.2.0 [INFO] [stderr] Compiling doc-comment v0.3.3 [INFO] [stderr] Compiling linux-raw-sys v0.3.8 [INFO] [stderr] Compiling futures-lite v1.13.0 [INFO] [stderr] Compiling async-lock v2.8.0 [INFO] [stderr] Compiling futures-util v0.3.31 [INFO] [stderr] Compiling flume v0.11.1 [INFO] [stderr] Compiling polling v3.9.0 [INFO] [stderr] Compiling rustls-connector v0.20.2 [INFO] [stderr] Compiling tcp-stream v0.28.0 [INFO] [stderr] Compiling async-io v2.5.0 [INFO] [stderr] Compiling amq-protocol-uri v7.2.3 [INFO] [stderr] Compiling proc-macro-crate v3.3.0 [INFO] [stderr] Compiling blocking v1.6.2 [INFO] [stderr] Compiling async-executor v1.13.2 [INFO] [stderr] Compiling reactor-trait v1.1.0 [INFO] [stderr] Compiling executor-trait v2.1.2 [INFO] [stderr] Compiling socket2 v0.4.10 [INFO] [stderr] Compiling rustls v0.22.4 [INFO] [stderr] Compiling amq-protocol v7.2.3 [INFO] [stderr] Compiling async-global-executor v3.1.0 [INFO] [stderr] Compiling amq-protocol-tcp v7.2.3 [INFO] [stderr] Compiling rdkafka-sys v4.9.0+2.10.0 [INFO] [stderr] Compiling rustls-webpki v0.102.8 [INFO] [stderr] Compiling lapin v2.5.4 [INFO] [stderr] Compiling num_enum_derive v0.7.4 [INFO] [stderr] Compiling async-reactor-trait v1.1.0 [INFO] [stderr] Compiling async-global-executor-trait v2.2.0 [INFO] [stderr] Compiling pinky-swear v6.2.0 [INFO] [stderr] Compiling num_enum v0.7.4 [INFO] [stderr] Compiling tokio-stream v0.1.17 [INFO] [stderr] Compiling thiserror-impl v1.0.69 [INFO] [stderr] Compiling futures-executor v0.3.31 [INFO] [stderr] Compiling tokio-executor-trait v2.1.3 [INFO] [stderr] Compiling futures v0.3.31 [INFO] [stderr] Compiling bincode v1.3.3 [INFO] [stderr] Compiling tokio-reactor-trait v1.1.0 [INFO] [stderr] Compiling uuid v1.17.0 [INFO] [stderr] Compiling thiserror v1.0.69 [INFO] [stderr] Compiling tokio-rustls v0.25.0 [INFO] [stderr] Compiling rumqttc v0.24.0 [INFO] [stderr] Compiling tokio-amqp v2.0.0 [INFO] [stderr] Compiling rdkafka v0.36.2 [INFO] [stderr] Compiling kincir v0.2.0 (/opt/rustwide/workdir) [INFO] [stdout] warning: unused import: `std::collections::HashMap` [INFO] [stdout] --> src/memory/stats.rs:1:5 [INFO] [stdout] | [INFO] [stdout] 1 | use std::collections::HashMap; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_imports)]` on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `start_time` [INFO] [stdout] --> src/memory/publisher.rs:66:13 [INFO] [stdout] | [INFO] [stdout] 66 | let start_time = Instant::now(); [INFO] [stdout] | ^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_start_time` [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_variables)]` on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: field `broker` is never read [INFO] [stdout] --> src/memory/ack_fixed.rs:27:5 [INFO] [stdout] | [INFO] [stdout] 17 | pub struct InMemoryAckHandleFixed { [INFO] [stdout] | ---------------------- field in this struct [INFO] [stdout] ... [INFO] [stdout] 27 | broker: Weak, [INFO] [stdout] | ^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `InMemoryAckHandleFixed` has derived impls for the traits `Clone` and `Debug`, but these are intentionally ignored during dead code analysis [INFO] [stdout] = note: `#[warn(dead_code)]` on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: method `remove_subscriber` is never used [INFO] [stdout] --> src/memory/broker.rs:120:8 [INFO] [stdout] | [INFO] [stdout] 30 | impl TopicData { [INFO] [stdout] | -------------- method in this implementation [INFO] [stdout] ... [INFO] [stdout] 120 | fn remove_subscriber(&mut self, sender_id: &mpsc::UnboundedSender) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: method `estimate_memory_usage` is never used [INFO] [stdout] --> src/memory/broker.rs:544:8 [INFO] [stdout] | [INFO] [stdout] 172 | impl InMemoryBroker { [INFO] [stdout] | ------------------- method in this implementation [INFO] [stdout] ... [INFO] [stdout] 544 | fn estimate_memory_usage(&self) -> usize { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: field `event_loop` is never read [INFO] [stdout] --> src/mqtt/ack.rs:103:5 [INFO] [stdout] | [INFO] [stdout] 99 | pub struct MQTTAckSubscriber { [INFO] [stdout] | ----------------- field in this struct [INFO] [stdout] ... [INFO] [stdout] 103 | event_loop: Arc>, [INFO] [stdout] | ^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated function `handle_event_loop` is never used [INFO] [stdout] --> src/mqtt/ack.rs:223:14 [INFO] [stdout] | [INFO] [stdout] 122 | impl MQTTAckSubscriber { [INFO] [stdout] | ---------------------- associated function in this implementation [INFO] [stdout] ... [INFO] [stdout] 223 | async fn handle_event_loop( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stderr] Finished `dev` profile [unoptimized + debuginfo] target(s) in 4m 20s [INFO] running `Command { std: "docker" "inspect" "473eb46a20e9979fc09c9161856720b656f3dedd3268331a85a02cf90427f55a", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "473eb46a20e9979fc09c9161856720b656f3dedd3268331a85a02cf90427f55a", kill_on_drop: false }` [INFO] [stdout] 473eb46a20e9979fc09c9161856720b656f3dedd3268331a85a02cf90427f55a [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-2-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-2-tc1/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=warn" "-e" "RUSTDOCFLAGS=--cap-lints=warn" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:e90291280db7d1fac5b66fc6dad9f9662629e7365a55743daf9bdf73ebc4ea79" "/opt/rustwide/cargo-home/bin/cargo" "+1.90.0" "test" "--frozen" "--no-run" "--message-format=json", kill_on_drop: false }` [INFO] [stdout] 32fd46a3d10a53eb828b428a4f77f9ec842f73d6436ab32dac341485886b28fa [INFO] running `Command { std: "docker" "start" "-a" "32fd46a3d10a53eb828b428a4f77f9ec842f73d6436ab32dac341485886b28fa", kill_on_drop: false }` [INFO] [stderr] Compiling getrandom v0.2.16 [INFO] [stderr] Compiling serde v1.0.219 [INFO] [stderr] Compiling rustix v1.0.8 [INFO] [stderr] Compiling event-listener v5.4.0 [INFO] [stderr] Compiling tokio v1.46.1 [INFO] [stderr] Compiling tracing-core v0.1.34 [INFO] [stderr] Compiling futures-util v0.3.31 [INFO] [stderr] Compiling polling v2.8.0 [INFO] [stderr] Compiling ring v0.17.14 [INFO] [stderr] Compiling event-listener-strategy v0.5.4 [INFO] [stderr] Compiling async-executor v1.13.2 [INFO] [stderr] Compiling async-channel v2.5.0 [INFO] [stderr] Compiling tracing v0.1.41 [INFO] [stderr] Compiling async-lock v3.4.0 [INFO] [stderr] Compiling blocking v1.6.2 [INFO] [stderr] Compiling async-io v1.13.0 [INFO] [stderr] Compiling pinky-swear v6.2.0 [INFO] [stderr] Compiling async-reactor-trait v1.1.0 [INFO] [stderr] Compiling half v2.6.0 [INFO] [stderr] Compiling plotters-backend v0.3.7 [INFO] [stderr] Compiling ciborium-io v0.2.2 [INFO] [stderr] Compiling clap_builder v4.5.41 [INFO] [stderr] Compiling plotters-svg v0.3.7 [INFO] [stderr] Compiling ciborium-ll v0.2.2 [INFO] [stderr] Compiling regex-automata v0.4.9 [INFO] [stderr] Compiling itertools v0.10.5 [INFO] [stderr] Compiling rustls-webpki v0.103.4 [INFO] [stderr] Compiling serde_json v1.0.141 [INFO] [stderr] Compiling rustls-webpki v0.102.8 [INFO] [stderr] Compiling futures-executor v0.3.31 [INFO] [stderr] Compiling rustls v0.23.29 [INFO] [stderr] Compiling amq-protocol-types v7.2.3 [INFO] [stderr] Compiling polling v3.9.0 [INFO] [stderr] Compiling amq-protocol-uri v7.2.3 [INFO] [stderr] Compiling async-io v2.5.0 [INFO] [stderr] Compiling rustls v0.22.4 [INFO] [stderr] Compiling tempfile v3.20.0 [INFO] [stderr] Compiling tokio-stream v0.1.17 [INFO] [stderr] Compiling async-global-executor v3.1.0 [INFO] [stderr] Compiling tokio-executor-trait v2.1.3 [INFO] [stderr] Compiling async-global-executor-trait v2.2.0 [INFO] [stderr] Compiling tokio-reactor-trait v1.1.0 [INFO] [stderr] Compiling rand_core v0.6.4 [INFO] [stderr] Compiling async-stream-impl v0.3.6 [INFO] [stderr] Compiling wait-timeout v0.2.1 [INFO] [stderr] Compiling cast v0.3.0 [INFO] [stderr] Compiling bit-vec v0.8.0 [INFO] [stderr] Compiling rusty-fork v0.3.0 [INFO] [stderr] Compiling criterion-plot v0.5.0 [INFO] [stderr] Compiling walkdir v2.5.0 [INFO] [stderr] Compiling async-stream v0.3.6 [INFO] [stderr] Compiling bit-set v0.8.0 [INFO] [stderr] Compiling rand_chacha v0.3.1 [INFO] [stderr] Compiling rdkafka v0.36.2 [INFO] [stderr] Compiling tinytemplate v1.2.1 [INFO] [stderr] Compiling regex v1.11.1 [INFO] [stderr] Compiling futures v0.3.31 [INFO] [stderr] Compiling clap v4.5.41 [INFO] [stderr] Compiling ciborium v0.2.2 [INFO] [stderr] Compiling rustls-connector v0.20.2 [INFO] [stderr] Compiling tcp-stream v0.28.0 [INFO] [stderr] Compiling bincode v1.3.3 [INFO] [stderr] Compiling tokio-rustls v0.25.0 [INFO] [stderr] Compiling amq-protocol-tcp v7.2.3 [INFO] [stderr] Compiling amq-protocol v7.2.3 [INFO] [stderr] Compiling rumqttc v0.24.0 [INFO] [stderr] Compiling rayon v1.10.0 [INFO] [stderr] Compiling plotters v0.3.7 [INFO] [stderr] Compiling tracing-log v0.2.0 [INFO] [stderr] Compiling sharded-slab v0.1.7 [INFO] [stderr] Compiling lapin v2.5.4 [INFO] [stderr] Compiling rand_xorshift v0.4.0 [INFO] [stderr] Compiling is-terminal v0.4.16 [INFO] [stderr] Compiling oorandom v11.1.5 [INFO] [stderr] Compiling unarray v0.1.4 [INFO] [stderr] Compiling anes v0.1.6 [INFO] [stderr] Compiling proptest v1.7.0 [INFO] [stderr] Compiling chrono v0.4.41 [INFO] [stderr] Compiling tracing-subscriber v0.3.19 [INFO] [stderr] Compiling criterion v0.5.1 [INFO] [stderr] Compiling rand v0.8.5 [INFO] [stderr] Compiling tokio-test v0.4.4 [INFO] [stderr] Compiling tokio-amqp v2.0.0 [INFO] [stderr] Compiling kincir v0.2.0 (/opt/rustwide/workdir) [INFO] [stdout] warning: unused import: `std::collections::HashMap` [INFO] [stdout] --> src/memory/stats.rs:1:5 [INFO] [stdout] | [INFO] [stdout] 1 | use std::collections::HashMap; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_imports)]` on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `start_time` [INFO] [stdout] --> src/memory/publisher.rs:66:13 [INFO] [stdout] | [INFO] [stdout] 66 | let start_time = Instant::now(); [INFO] [stdout] | ^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_start_time` [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_variables)]` on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error: expected expression, found `,` [INFO] [stdout] --> src/rabbitmq/tests.rs:286:95 [INFO] [stdout] | [INFO] [stdout] 286 | let handle = RabbitMQAckHandle::new(message.uuid.clone(), queue_name, SystemTime::now(, delivery_count, delivery_tag), [INFO] [stdout] | ^ expected expression [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error: expected expression, found `,` [INFO] [stdout] --> src/rabbitmq/tests.rs:334:100 [INFO] [stdout] | [INFO] [stdout] 334 | let handle = RabbitMQAckHandle::new(message_id.clone(), queue.clone(), SystemTime::now(, count, delivery_tag), [INFO] [stdout] | ^ expected expression [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `AckSubscriber` [INFO] [stdout] --> src/kafka/tests.rs:8:29 [INFO] [stdout] | [INFO] [stdout] 8 | use crate::ack::{AckHandle, AckSubscriber}; [INFO] [stdout] | ^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_imports)]` on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `std::time::Duration` [INFO] [stdout] --> src/memory/ack.rs:236:9 [INFO] [stdout] | [INFO] [stdout] 236 | use std::time::Duration; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused imports: `Message` and `Publisher` [INFO] [stdout] --> src/memory/ack_tests.rs:8:17 [INFO] [stdout] | [INFO] [stdout] 8 | use crate::{Publisher, Message}; [INFO] [stdout] | ^^^^^^^^^ ^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `std::collections::HashMap` [INFO] [stdout] --> src/memory/stats.rs:1:5 [INFO] [stdout] | [INFO] [stdout] 1 | use std::collections::HashMap; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `std::thread` [INFO] [stdout] --> src/memory/stats.rs:266:9 [INFO] [stdout] | [INFO] [stdout] 266 | use std::thread; [INFO] [stdout] | ^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `AckSubscriber` [INFO] [stdout] --> src/mqtt/tests.rs:8:29 [INFO] [stdout] | [INFO] [stdout] 8 | use crate::ack::{AckHandle, AckSubscriber}; [INFO] [stdout] | ^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `AckSubscriber` [INFO] [stdout] --> src/rabbitmq/tests.rs:8:29 [INFO] [stdout] | [INFO] [stdout] 8 | use crate::ack::{AckHandle, AckSubscriber}; [INFO] [stdout] | ^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: arguments to this function are incorrect [INFO] [stdout] --> src/kafka/tests.rs:26:22 [INFO] [stdout] | [INFO] [stdout] 26 | let handle = KafkaAckHandle::new( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 29 | partition, [INFO] [stdout] | --------- expected `std::time::SystemTime`, found `{integer}` [INFO] [stdout] ... [INFO] [stdout] 32 | timestamp, [INFO] [stdout] | --------- expected `i64`, found `std::time::SystemTime` [INFO] [stdout] | [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/kafka/ack.rs:37:12 [INFO] [stdout] | [INFO] [stdout] 37 | pub fn new( [INFO] [stdout] | ^^^ [INFO] [stdout] help: swap these arguments [INFO] [stdout] | [INFO] [stdout] 26 - let handle = KafkaAckHandle::new( [INFO] [stdout] 27 - message_id.clone(), [INFO] [stdout] 28 - topic.clone(), [INFO] [stdout] 29 - partition, [INFO] [stdout] 30 - offset, [INFO] [stdout] 31 - delivery_count, [INFO] [stdout] 32 - timestamp, [INFO] [stdout] 33 - ); [INFO] [stdout] 26 + let handle = KafkaAckHandle::new(message_id.clone(), topic.clone(), timestamp, offset, delivery_count, partition); [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: mismatched types [INFO] [stdout] --> src/kafka/tests.rs:38:9 [INFO] [stdout] | [INFO] [stdout] 38 | assert_eq!(handle.offset(), offset); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ expected `i64`, found `u32` [INFO] [stdout] | [INFO] [stdout] = note: this error originates in the macro `assert_eq` (in Nightly builds, run with -Z macro-backtrace for more info) [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: can't compare `i64` with `u32` [INFO] [stdout] --> src/kafka/tests.rs:38:9 [INFO] [stdout] | [INFO] [stdout] 38 | assert_eq!(handle.offset(), offset); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ no implementation for `i64 == u32` [INFO] [stdout] | [INFO] [stdout] = help: the trait `PartialEq` is not implemented for `i64` [INFO] [stdout] = help: the following other types implement trait `PartialEq`: [INFO] [stdout] `i64` implements `PartialEq` [INFO] [stdout] `i64` implements `PartialEq` [INFO] [stdout] = note: this error originates in the macro `assert_eq` (in Nightly builds, run with -Z macro-backtrace for more info) [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: mismatched types [INFO] [stdout] --> src/kafka/tests.rs:39:9 [INFO] [stdout] | [INFO] [stdout] 39 | assert_eq!(handle.delivery_count(), delivery_count); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ expected `u32`, found `i32` [INFO] [stdout] | [INFO] [stdout] = note: this error originates in the macro `assert_eq` (in Nightly builds, run with -Z macro-backtrace for more info) [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: can't compare `u32` with `i32` [INFO] [stdout] --> src/kafka/tests.rs:39:9 [INFO] [stdout] | [INFO] [stdout] 39 | assert_eq!(handle.delivery_count(), delivery_count); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ no implementation for `u32 == i32` [INFO] [stdout] | [INFO] [stdout] = help: the trait `PartialEq` is not implemented for `u32` [INFO] [stdout] = help: the following other types implement trait `PartialEq`: [INFO] [stdout] `u32` implements `PartialEq` [INFO] [stdout] `u32` implements `PartialEq` [INFO] [stdout] = note: this error originates in the macro `assert_eq` (in Nightly builds, run with -Z macro-backtrace for more info) [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: arguments to this function are incorrect [INFO] [stdout] --> src/kafka/tests.rs:53:28 [INFO] [stdout] | [INFO] [stdout] 53 | let handle_first = KafkaAckHandle::new( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 56 | partition, [INFO] [stdout] | --------- expected `std::time::SystemTime`, found `{integer}` [INFO] [stdout] ... [INFO] [stdout] 59 | timestamp, [INFO] [stdout] | --------- expected `i64`, found `std::time::SystemTime` [INFO] [stdout] | [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/kafka/ack.rs:37:12 [INFO] [stdout] | [INFO] [stdout] 37 | pub fn new( [INFO] [stdout] | ^^^ [INFO] [stdout] help: swap these arguments [INFO] [stdout] | [INFO] [stdout] 53 - let handle_first = KafkaAckHandle::new( [INFO] [stdout] 54 - message_id.clone(), [INFO] [stdout] 55 - topic.clone(), [INFO] [stdout] 56 - partition, [INFO] [stdout] 57 - offset, [INFO] [stdout] 58 - 1, // delivery_count = 1 [INFO] [stdout] 59 - timestamp, [INFO] [stdout] 60 - ); [INFO] [stdout] 53 + let handle_first = KafkaAckHandle::new(message_id.clone(), topic.clone(), timestamp, offset, 1, partition); [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: arguments to this function are incorrect [INFO] [stdout] --> src/kafka/tests.rs:64:28 [INFO] [stdout] | [INFO] [stdout] 64 | let handle_retry = KafkaAckHandle::new( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 67 | partition, [INFO] [stdout] | --------- expected `std::time::SystemTime`, found `{integer}` [INFO] [stdout] ... [INFO] [stdout] 70 | timestamp, [INFO] [stdout] | --------- expected `i64`, found `std::time::SystemTime` [INFO] [stdout] | [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/kafka/ack.rs:37:12 [INFO] [stdout] | [INFO] [stdout] 37 | pub fn new( [INFO] [stdout] | ^^^ [INFO] [stdout] help: swap these arguments [INFO] [stdout] | [INFO] [stdout] 64 - let handle_retry = KafkaAckHandle::new( [INFO] [stdout] 65 - message_id.clone(), [INFO] [stdout] 66 - topic.clone(), [INFO] [stdout] 67 - partition, [INFO] [stdout] 68 - offset, [INFO] [stdout] 69 - 2, // delivery_count = 2 [INFO] [stdout] 70 - timestamp, [INFO] [stdout] 71 - ); [INFO] [stdout] 64 + let handle_retry = KafkaAckHandle::new(message_id.clone(), topic.clone(), timestamp, offset, 2, partition); [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: arguments to this function are incorrect [INFO] [stdout] --> src/kafka/tests.rs:75:37 [INFO] [stdout] | [INFO] [stdout] 75 | let handle_multiple_retry = KafkaAckHandle::new( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 78 | partition, [INFO] [stdout] | --------- expected `std::time::SystemTime`, found `{integer}` [INFO] [stdout] ... [INFO] [stdout] 81 | timestamp, [INFO] [stdout] | --------- expected `i64`, found `std::time::SystemTime` [INFO] [stdout] | [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/kafka/ack.rs:37:12 [INFO] [stdout] | [INFO] [stdout] 37 | pub fn new( [INFO] [stdout] | ^^^ [INFO] [stdout] help: swap these arguments [INFO] [stdout] | [INFO] [stdout] 75 - let handle_multiple_retry = KafkaAckHandle::new( [INFO] [stdout] 76 - message_id, [INFO] [stdout] 77 - topic, [INFO] [stdout] 78 - partition, [INFO] [stdout] 79 - offset, [INFO] [stdout] 80 - 5, // delivery_count = 5 [INFO] [stdout] 81 - timestamp, [INFO] [stdout] 82 - ); [INFO] [stdout] 75 + let handle_multiple_retry = KafkaAckHandle::new(message_id, topic, timestamp, offset, 5, partition); [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: arguments to this function are incorrect [INFO] [stdout] --> src/kafka/tests.rs:95:23 [INFO] [stdout] | [INFO] [stdout] 95 | let handle1 = KafkaAckHandle::new( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 98 | partition, [INFO] [stdout] | --------- expected `std::time::SystemTime`, found `{integer}` [INFO] [stdout] ... [INFO] [stdout] 101 | timestamp, [INFO] [stdout] | --------- expected `i64`, found `std::time::SystemTime` [INFO] [stdout] | [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/kafka/ack.rs:37:12 [INFO] [stdout] | [INFO] [stdout] 37 | pub fn new( [INFO] [stdout] | ^^^ [INFO] [stdout] help: swap these arguments [INFO] [stdout] | [INFO] [stdout] 95 - let handle1 = KafkaAckHandle::new( [INFO] [stdout] 96 - message_id.clone(), [INFO] [stdout] 97 - topic.clone(), [INFO] [stdout] 98 - partition, [INFO] [stdout] 99 - offset, [INFO] [stdout] 100 - delivery_count, [INFO] [stdout] 101 - timestamp, [INFO] [stdout] 102 - ); [INFO] [stdout] 95 + let handle1 = KafkaAckHandle::new(message_id.clone(), topic.clone(), timestamp, offset, delivery_count, partition); [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: arguments to this function are incorrect [INFO] [stdout] --> src/kafka/tests.rs:104:23 [INFO] [stdout] | [INFO] [stdout] 104 | let handle2 = KafkaAckHandle::new( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 107 | partition, [INFO] [stdout] | --------- expected `std::time::SystemTime`, found `{integer}` [INFO] [stdout] ... [INFO] [stdout] 110 | timestamp, [INFO] [stdout] | --------- expected `i64`, found `std::time::SystemTime` [INFO] [stdout] | [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/kafka/ack.rs:37:12 [INFO] [stdout] | [INFO] [stdout] 37 | pub fn new( [INFO] [stdout] | ^^^ [INFO] [stdout] help: swap these arguments [INFO] [stdout] | [INFO] [stdout] 104 - let handle2 = KafkaAckHandle::new( [INFO] [stdout] 105 - message_id, [INFO] [stdout] 106 - topic, [INFO] [stdout] 107 - partition, [INFO] [stdout] 108 - offset, [INFO] [stdout] 109 - delivery_count, [INFO] [stdout] 110 - timestamp, [INFO] [stdout] 111 - ); [INFO] [stdout] 104 + let handle2 = KafkaAckHandle::new(message_id, topic, timestamp, offset, delivery_count, partition); [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: arguments to this function are incorrect [INFO] [stdout] --> src/kafka/tests.rs:132:26 [INFO] [stdout] | [INFO] [stdout] 132 | let handle = KafkaAckHandle::new( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 135 | partition, [INFO] [stdout] | --------- expected `std::time::SystemTime`, found `{integer}` [INFO] [stdout] 136 | offset, [INFO] [stdout] | ------ expected `u32`, found `u64` [INFO] [stdout] 137 | 1, [INFO] [stdout] 138 | timestamp, [INFO] [stdout] | --------- expected `i64`, found `std::time::SystemTime` [INFO] [stdout] | [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/kafka/ack.rs:37:12 [INFO] [stdout] | [INFO] [stdout] 37 | pub fn new( [INFO] [stdout] | ^^^ [INFO] [stdout] ... [INFO] [stdout] 41 | delivery_count: u32, [INFO] [stdout] | ------------------- [INFO] [stdout] help: you can convert a `u64` to a `u32` and panic if the converted value doesn't fit [INFO] [stdout] | [INFO] [stdout] 136 | offset.try_into().unwrap(), [INFO] [stdout] | ++++++++++++++++++++ [INFO] [stdout] help: swap these arguments [INFO] [stdout] | [INFO] [stdout] 132 - let handle = KafkaAckHandle::new( [INFO] [stdout] 133 - message_id.clone(), [INFO] [stdout] 134 - topic.clone(), [INFO] [stdout] 135 - partition, [INFO] [stdout] 136 - offset, [INFO] [stdout] 137 - 1, [INFO] [stdout] 138 - timestamp, [INFO] [stdout] 139 - ); [INFO] [stdout] 132 + let handle = KafkaAckHandle::new(message_id.clone(), topic.clone(), timestamp, /* u32 */, 1, partition); [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: mismatched types [INFO] [stdout] --> src/kafka/tests.rs:142:13 [INFO] [stdout] | [INFO] [stdout] 142 | assert_eq!(handle.offset(), offset); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ expected `i64`, found `u64` [INFO] [stdout] | [INFO] [stdout] = note: this error originates in the macro `assert_eq` (in Nightly builds, run with -Z macro-backtrace for more info) [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: can't compare `i64` with `u64` [INFO] [stdout] --> src/kafka/tests.rs:142:13 [INFO] [stdout] | [INFO] [stdout] 142 | assert_eq!(handle.offset(), offset); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ no implementation for `i64 == u64` [INFO] [stdout] | [INFO] [stdout] = help: the trait `PartialEq` is not implemented for `i64` [INFO] [stdout] = help: the following other types implement trait `PartialEq`: [INFO] [stdout] `i64` implements `PartialEq` [INFO] [stdout] `i64` implements `PartialEq` [INFO] [stdout] = note: this error originates in the macro `assert_eq` (in Nightly builds, run with -Z macro-backtrace for more info) [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: arguments to this function are incorrect [INFO] [stdout] --> src/kafka/tests.rs:156:22 [INFO] [stdout] | [INFO] [stdout] 156 | let handle = KafkaAckHandle::new( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 159 | partition, [INFO] [stdout] | --------- expected `std::time::SystemTime`, found `{integer}` [INFO] [stdout] ... [INFO] [stdout] 162 | timestamp, [INFO] [stdout] | --------- expected `i64`, found `std::time::SystemTime` [INFO] [stdout] | [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/kafka/ack.rs:37:12 [INFO] [stdout] | [INFO] [stdout] 37 | pub fn new( [INFO] [stdout] | ^^^ [INFO] [stdout] help: swap these arguments [INFO] [stdout] | [INFO] [stdout] 156 - let handle = KafkaAckHandle::new( [INFO] [stdout] 157 - message_id.clone(), [INFO] [stdout] 158 - topic.clone(), [INFO] [stdout] 159 - partition, [INFO] [stdout] 160 - offset, [INFO] [stdout] 161 - delivery_count, [INFO] [stdout] 162 - timestamp, [INFO] [stdout] 163 - ); [INFO] [stdout] 156 + let handle = KafkaAckHandle::new(message_id.clone(), topic.clone(), timestamp, offset, delivery_count, partition); [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: mismatched types [INFO] [stdout] --> src/kafka/tests.rs:168:9 [INFO] [stdout] | [INFO] [stdout] 168 | assert_eq!(handle.delivery_count(), delivery_count); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ expected `u32`, found `i32` [INFO] [stdout] | [INFO] [stdout] = note: this error originates in the macro `assert_eq` (in Nightly builds, run with -Z macro-backtrace for more info) [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: can't compare `u32` with `i32` [INFO] [stdout] --> src/kafka/tests.rs:168:9 [INFO] [stdout] | [INFO] [stdout] 168 | assert_eq!(handle.delivery_count(), delivery_count); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ no implementation for `u32 == i32` [INFO] [stdout] | [INFO] [stdout] = help: the trait `PartialEq` is not implemented for `u32` [INFO] [stdout] = help: the following other types implement trait `PartialEq`: [INFO] [stdout] `u32` implements `PartialEq` [INFO] [stdout] `u32` implements `PartialEq` [INFO] [stdout] = note: this error originates in the macro `assert_eq` (in Nightly builds, run with -Z macro-backtrace for more info) [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: mismatched types [INFO] [stdout] --> src/kafka/tests.rs:174:9 [INFO] [stdout] | [INFO] [stdout] 174 | assert_eq!(handle.offset(), offset); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ expected `i64`, found `u32` [INFO] [stdout] | [INFO] [stdout] = note: this error originates in the macro `assert_eq` (in Nightly builds, run with -Z macro-backtrace for more info) [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: can't compare `i64` with `u32` [INFO] [stdout] --> src/kafka/tests.rs:174:9 [INFO] [stdout] | [INFO] [stdout] 174 | assert_eq!(handle.offset(), offset); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ no implementation for `i64 == u32` [INFO] [stdout] | [INFO] [stdout] = help: the trait `PartialEq` is not implemented for `i64` [INFO] [stdout] = help: the following other types implement trait `PartialEq`: [INFO] [stdout] `i64` implements `PartialEq` [INFO] [stdout] `i64` implements `PartialEq` [INFO] [stdout] = note: this error originates in the macro `assert_eq` (in Nightly builds, run with -Z macro-backtrace for more info) [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: arguments to this function are incorrect [INFO] [stdout] --> src/kafka/tests.rs:187:22 [INFO] [stdout] | [INFO] [stdout] 187 | let handle = KafkaAckHandle::new( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 190 | partition, [INFO] [stdout] | --------- expected `std::time::SystemTime`, found `{integer}` [INFO] [stdout] ... [INFO] [stdout] 193 | timestamp, [INFO] [stdout] | --------- expected `i64`, found `std::time::SystemTime` [INFO] [stdout] | [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/kafka/ack.rs:37:12 [INFO] [stdout] | [INFO] [stdout] 37 | pub fn new( [INFO] [stdout] | ^^^ [INFO] [stdout] help: swap these arguments [INFO] [stdout] | [INFO] [stdout] 187 - let handle = KafkaAckHandle::new( [INFO] [stdout] 188 - message_id.clone(), [INFO] [stdout] 189 - topic.clone(), [INFO] [stdout] 190 - partition, [INFO] [stdout] 191 - offset, [INFO] [stdout] 192 - delivery_count, [INFO] [stdout] 193 - timestamp, [INFO] [stdout] 194 - ); [INFO] [stdout] 187 + let handle = KafkaAckHandle::new(message_id.clone(), topic.clone(), timestamp, offset, delivery_count, partition); [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: mismatched types [INFO] [stdout] --> src/kafka/tests.rs:199:9 [INFO] [stdout] | [INFO] [stdout] 199 | assert_eq!(handle.offset(), offset); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ expected `i64`, found `u32` [INFO] [stdout] | [INFO] [stdout] = note: this error originates in the macro `assert_eq` (in Nightly builds, run with -Z macro-backtrace for more info) [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: can't compare `i64` with `u32` [INFO] [stdout] --> src/kafka/tests.rs:199:9 [INFO] [stdout] | [INFO] [stdout] 199 | assert_eq!(handle.offset(), offset); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ no implementation for `i64 == u32` [INFO] [stdout] | [INFO] [stdout] = help: the trait `PartialEq` is not implemented for `i64` [INFO] [stdout] = help: the following other types implement trait `PartialEq`: [INFO] [stdout] `i64` implements `PartialEq` [INFO] [stdout] `i64` implements `PartialEq` [INFO] [stdout] = note: this error originates in the macro `assert_eq` (in Nightly builds, run with -Z macro-backtrace for more info) [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: mismatched types [INFO] [stdout] --> src/kafka/tests.rs:200:9 [INFO] [stdout] | [INFO] [stdout] 200 | assert_eq!(handle.delivery_count(), delivery_count); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ expected `u32`, found `i32` [INFO] [stdout] | [INFO] [stdout] = note: this error originates in the macro `assert_eq` (in Nightly builds, run with -Z macro-backtrace for more info) [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: can't compare `u32` with `i32` [INFO] [stdout] --> src/kafka/tests.rs:200:9 [INFO] [stdout] | [INFO] [stdout] 200 | assert_eq!(handle.delivery_count(), delivery_count); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ no implementation for `u32 == i32` [INFO] [stdout] | [INFO] [stdout] = help: the trait `PartialEq` is not implemented for `u32` [INFO] [stdout] = help: the following other types implement trait `PartialEq`: [INFO] [stdout] `u32` implements `PartialEq` [INFO] [stdout] `u32` implements `PartialEq` [INFO] [stdout] = note: this error originates in the macro `assert_eq` (in Nightly builds, run with -Z macro-backtrace for more info) [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: `kafka::ack::KafkaAckSubscriber` doesn't implement `std::fmt::Debug` [INFO] [stdout] --> src/kafka/tests.rs:222:28 [INFO] [stdout] | [INFO] [stdout] 222 | let error = result.unwrap_err(); [INFO] [stdout] | ^^^^^^^^^^ the trait `std::fmt::Debug` is not implemented for `kafka::ack::KafkaAckSubscriber` [INFO] [stdout] | [INFO] [stdout] = note: add `#[derive(Debug)]` to `kafka::ack::KafkaAckSubscriber` or manually `impl std::fmt::Debug for kafka::ack::KafkaAckSubscriber` [INFO] [stdout] note: required by a bound in `Result::::unwrap_err` [INFO] [stdout] --> /rustc/1159e78c4747b02ef996e55082b704c09b970588/library/core/src/result.rs:1256:5 [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: arguments to this function are incorrect [INFO] [stdout] --> src/kafka/tests.rs:359:22 [INFO] [stdout] | [INFO] [stdout] 359 | let handle = KafkaAckHandle::new( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 362 | partition, [INFO] [stdout] | --------- expected `std::time::SystemTime`, found `i32` [INFO] [stdout] 363 | offset, [INFO] [stdout] | ------ unexpected argument #4 of type `u64` [INFO] [stdout] 364 | delivery_count, [INFO] [stdout] 365 | SystemTime::now(), [INFO] [stdout] | ----------------- [INFO] [stdout] | | [INFO] [stdout] | argument #6 of type `i64` is missing [INFO] [stdout] | expected `i32`, found `std::time::SystemTime` [INFO] [stdout] | [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/kafka/ack.rs:37:12 [INFO] [stdout] | [INFO] [stdout] 37 | pub fn new( [INFO] [stdout] | ^^^ [INFO] [stdout] ... [INFO] [stdout] 43 | offset: i64, [INFO] [stdout] | ----------- [INFO] [stdout] help: did you mean [INFO] [stdout] | [INFO] [stdout] 359 - let handle = KafkaAckHandle::new( [INFO] [stdout] 360 - message.uuid.clone(), [INFO] [stdout] 361 - topic, [INFO] [stdout] 362 - partition, [INFO] [stdout] 363 - offset, [INFO] [stdout] 364 - delivery_count, [INFO] [stdout] 365 - SystemTime::now(), [INFO] [stdout] 366 - ); [INFO] [stdout] 359 + let handle = KafkaAckHandle::new(message.uuid.clone(), topic, SystemTime::now(), delivery_count, partition, /* i64 */); [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: mismatched types [INFO] [stdout] --> src/kafka/tests.rs:370:9 [INFO] [stdout] | [INFO] [stdout] 370 | assert_eq!(handle.offset(), offset); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ expected `i64`, found `u64` [INFO] [stdout] | [INFO] [stdout] = note: this error originates in the macro `assert_eq` (in Nightly builds, run with -Z macro-backtrace for more info) [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: can't compare `i64` with `u64` [INFO] [stdout] --> src/kafka/tests.rs:370:9 [INFO] [stdout] | [INFO] [stdout] 370 | assert_eq!(handle.offset(), offset); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ no implementation for `i64 == u64` [INFO] [stdout] | [INFO] [stdout] = help: the trait `PartialEq` is not implemented for `i64` [INFO] [stdout] = help: the following other types implement trait `PartialEq`: [INFO] [stdout] `i64` implements `PartialEq` [INFO] [stdout] `i64` implements `PartialEq` [INFO] [stdout] = note: this error originates in the macro `assert_eq` (in Nightly builds, run with -Z macro-backtrace for more info) [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: arguments to this function are incorrect [INFO] [stdout] --> src/kafka/tests.rs:379:13 [INFO] [stdout] | [INFO] [stdout] 379 | KafkaAckHandle::new("msg1".to_string(), "topic".to_string(), 0, 100, 1, SystemTime::now()), [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ - ----------------- expected `i64`, found `std::time::SystemTime` [INFO] [stdout] | | [INFO] [stdout] | expected `std::time::SystemTime`, found `{integer}` [INFO] [stdout] | [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/kafka/ack.rs:37:12 [INFO] [stdout] | [INFO] [stdout] 37 | pub fn new( [INFO] [stdout] | ^^^ [INFO] [stdout] help: swap these arguments [INFO] [stdout] | [INFO] [stdout] 379 - KafkaAckHandle::new("msg1".to_string(), "topic".to_string(), 0, 100, 1, SystemTime::now()), [INFO] [stdout] 379 + KafkaAckHandle::new("msg1".to_string(), "topic".to_string(), SystemTime::now(), 100, 1, 0), [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: arguments to this function are incorrect [INFO] [stdout] --> src/kafka/tests.rs:380:13 [INFO] [stdout] | [INFO] [stdout] 380 | KafkaAckHandle::new("msg2".to_string(), "topic".to_string(), 0, 101, 1, SystemTime::now()), [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ - ----------------- expected `i64`, found `std::time::SystemTime` [INFO] [stdout] | | [INFO] [stdout] | expected `std::time::SystemTime`, found `{integer}` [INFO] [stdout] | [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/kafka/ack.rs:37:12 [INFO] [stdout] | [INFO] [stdout] 37 | pub fn new( [INFO] [stdout] | ^^^ [INFO] [stdout] help: swap these arguments [INFO] [stdout] | [INFO] [stdout] 380 - KafkaAckHandle::new("msg2".to_string(), "topic".to_string(), 0, 101, 1, SystemTime::now()), [INFO] [stdout] 380 + KafkaAckHandle::new("msg2".to_string(), "topic".to_string(), SystemTime::now(), 101, 1, 0), [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: arguments to this function are incorrect [INFO] [stdout] --> src/kafka/tests.rs:381:13 [INFO] [stdout] | [INFO] [stdout] 381 | KafkaAckHandle::new("msg3".to_string(), "topic".to_string(), 0, 102, 1, SystemTime::now()), [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ - ----------------- expected `i64`, found `std::time::SystemTime` [INFO] [stdout] | | [INFO] [stdout] | expected `std::time::SystemTime`, found `{integer}` [INFO] [stdout] | [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/kafka/ack.rs:37:12 [INFO] [stdout] | [INFO] [stdout] 37 | pub fn new( [INFO] [stdout] | ^^^ [INFO] [stdout] help: swap these arguments [INFO] [stdout] | [INFO] [stdout] 381 - KafkaAckHandle::new("msg3".to_string(), "topic".to_string(), 0, 102, 1, SystemTime::now()), [INFO] [stdout] 381 + KafkaAckHandle::new("msg3".to_string(), "topic".to_string(), SystemTime::now(), 102, 1, 0), [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: arguments to this function are incorrect [INFO] [stdout] --> src/kafka/tests.rs:382:13 [INFO] [stdout] | [INFO] [stdout] 382 | KafkaAckHandle::new("msg4".to_string(), "topic".to_string(), 1, 200, 1, SystemTime::now()), [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ - ----------------- expected `i64`, found `std::time::SystemTime` [INFO] [stdout] | | [INFO] [stdout] | expected `std::time::SystemTime`, found `{integer}` [INFO] [stdout] | [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/kafka/ack.rs:37:12 [INFO] [stdout] | [INFO] [stdout] 37 | pub fn new( [INFO] [stdout] | ^^^ [INFO] [stdout] help: swap these arguments [INFO] [stdout] | [INFO] [stdout] 382 - KafkaAckHandle::new("msg4".to_string(), "topic".to_string(), 1, 200, 1, SystemTime::now()), [INFO] [stdout] 382 + KafkaAckHandle::new("msg4".to_string(), "topic".to_string(), SystemTime::now(), 200, 1, 1), [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: arguments to this function are incorrect [INFO] [stdout] --> src/kafka/tests.rs:383:13 [INFO] [stdout] | [INFO] [stdout] 383 | KafkaAckHandle::new("msg5".to_string(), "topic".to_string(), 1, 201, 1, SystemTime::now()), [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ - ----------------- expected `i64`, found `std::time::SystemTime` [INFO] [stdout] | | [INFO] [stdout] | expected `std::time::SystemTime`, found `{integer}` [INFO] [stdout] | [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/kafka/ack.rs:37:12 [INFO] [stdout] | [INFO] [stdout] 37 | pub fn new( [INFO] [stdout] | ^^^ [INFO] [stdout] help: swap these arguments [INFO] [stdout] | [INFO] [stdout] 383 - KafkaAckHandle::new("msg5".to_string(), "topic".to_string(), 1, 201, 1, SystemTime::now()), [INFO] [stdout] 383 + KafkaAckHandle::new("msg5".to_string(), "topic".to_string(), SystemTime::now(), 201, 1, 1), [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: arguments to this function are incorrect [INFO] [stdout] --> src/kafka/tests.rs:420:26 [INFO] [stdout] | [INFO] [stdout] 420 | let handle = KafkaAckHandle::new( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 423 | partition, [INFO] [stdout] | --------- expected `std::time::SystemTime`, found `{integer}` [INFO] [stdout] ... [INFO] [stdout] 426 | timestamp, [INFO] [stdout] | --------- expected `i64`, found `std::time::SystemTime` [INFO] [stdout] | [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/kafka/ack.rs:37:12 [INFO] [stdout] | [INFO] [stdout] 37 | pub fn new( [INFO] [stdout] | ^^^ [INFO] [stdout] help: swap these arguments [INFO] [stdout] | [INFO] [stdout] 420 - let handle = KafkaAckHandle::new( [INFO] [stdout] 421 - format!("msg-{}", offset), [INFO] [stdout] 422 - topic.clone(), [INFO] [stdout] 423 - partition, [INFO] [stdout] 424 - offset, [INFO] [stdout] 425 - delivery_count, [INFO] [stdout] 426 - timestamp, [INFO] [stdout] 427 - ); [INFO] [stdout] 420 + let handle = KafkaAckHandle::new(format!("msg-{}", offset), topic.clone(), timestamp, offset, delivery_count, partition); [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: arguments to this function are incorrect [INFO] [stdout] --> src/kafka/tests.rs:463:26 [INFO] [stdout] | [INFO] [stdout] 463 | let handle = KafkaAckHandle::new( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 466 | partition, [INFO] [stdout] | --------- expected `std::time::SystemTime`, found `{integer}` [INFO] [stdout] 467 | 1000 + partition as u64, // Different offset per partition [INFO] [stdout] | ----------------------- expected `u32`, found `u64` [INFO] [stdout] 468 | 1, [INFO] [stdout] 469 | timestamp, [INFO] [stdout] | --------- expected `i64`, found `std::time::SystemTime` [INFO] [stdout] | [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/kafka/ack.rs:37:12 [INFO] [stdout] | [INFO] [stdout] 37 | pub fn new( [INFO] [stdout] | ^^^ [INFO] [stdout] ... [INFO] [stdout] 41 | delivery_count: u32, [INFO] [stdout] | ------------------- [INFO] [stdout] help: you can convert a `u64` to a `u32` and panic if the converted value doesn't fit [INFO] [stdout] | [INFO] [stdout] 467 | (1000 + partition as u64).try_into().unwrap(), // Different offset per partition [INFO] [stdout] | + +++++++++++++++++++++ [INFO] [stdout] help: swap these arguments [INFO] [stdout] | [INFO] [stdout] 463 - let handle = KafkaAckHandle::new( [INFO] [stdout] 464 - format!("msg-p{}", partition), [INFO] [stdout] 465 - topic.clone(), [INFO] [stdout] 466 - partition, [INFO] [stdout] 467 - 1000 + partition as u64, // Different offset per partition [INFO] [stdout] 468 - 1, [INFO] [stdout] 469 - timestamp, [INFO] [stdout] 470 - ); [INFO] [stdout] 463 + let handle = KafkaAckHandle::new(format!("msg-p{}", partition), topic.clone(), timestamp, /* u32 */, 1, partition); [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: mismatched types [INFO] [stdout] --> src/kafka/tests.rs:473:13 [INFO] [stdout] | [INFO] [stdout] 473 | assert_eq!(handle.offset(), 1000 + partition as u64); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ expected `i64`, found `u64` [INFO] [stdout] | [INFO] [stdout] = note: this error originates in the macro `assert_eq` (in Nightly builds, run with -Z macro-backtrace for more info) [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: can't compare `i64` with `u64` [INFO] [stdout] --> src/kafka/tests.rs:473:13 [INFO] [stdout] | [INFO] [stdout] 473 | assert_eq!(handle.offset(), 1000 + partition as u64); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ no implementation for `i64 == u64` [INFO] [stdout] | [INFO] [stdout] = help: the trait `PartialEq` is not implemented for `i64` [INFO] [stdout] = help: the following other types implement trait `PartialEq`: [INFO] [stdout] `i64` implements `PartialEq` [INFO] [stdout] `i64` implements `PartialEq` [INFO] [stdout] = note: this error originates in the macro `assert_eq` (in Nightly builds, run with -Z macro-backtrace for more info) [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: arguments to this function are incorrect [INFO] [stdout] --> src/kafka/tests.rs:494:26 [INFO] [stdout] | [INFO] [stdout] 494 | let handle = KafkaAckHandle::new( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 497 | partition, [INFO] [stdout] | --------- expected `std::time::SystemTime`, found `{integer}` [INFO] [stdout] ... [INFO] [stdout] 500 | SystemTime::now(), [INFO] [stdout] | ----------------- expected `i64`, found `std::time::SystemTime` [INFO] [stdout] | [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/kafka/ack.rs:37:12 [INFO] [stdout] | [INFO] [stdout] 37 | pub fn new( [INFO] [stdout] | ^^^ [INFO] [stdout] help: swap these arguments [INFO] [stdout] | [INFO] [stdout] 494 - let handle = KafkaAckHandle::new( [INFO] [stdout] 495 - message_id.clone(), [INFO] [stdout] 496 - topic.clone(), [INFO] [stdout] 497 - partition, [INFO] [stdout] 498 - offset, [INFO] [stdout] 499 - count, [INFO] [stdout] 500 - SystemTime::now(), [INFO] [stdout] 501 - ); [INFO] [stdout] 494 + let handle = KafkaAckHandle::new(message_id.clone(), topic.clone(), SystemTime::now(), offset, count, partition); [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: mismatched types [INFO] [stdout] --> src/kafka/tests.rs:505:13 [INFO] [stdout] | [INFO] [stdout] 505 | assert_eq!(handle.delivery_count(), count); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ expected `u32`, found `i32` [INFO] [stdout] | [INFO] [stdout] = note: this error originates in the macro `assert_eq` (in Nightly builds, run with -Z macro-backtrace for more info) [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: can't compare `u32` with `i32` [INFO] [stdout] --> src/kafka/tests.rs:505:13 [INFO] [stdout] | [INFO] [stdout] 505 | assert_eq!(handle.delivery_count(), count); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ no implementation for `u32 == i32` [INFO] [stdout] | [INFO] [stdout] = help: the trait `PartialEq` is not implemented for `u32` [INFO] [stdout] = help: the following other types implement trait `PartialEq`: [INFO] [stdout] `u32` implements `PartialEq` [INFO] [stdout] `u32` implements `PartialEq` [INFO] [stdout] = note: this error originates in the macro `assert_eq` (in Nightly builds, run with -Z macro-backtrace for more info) [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: arguments to this function are incorrect [INFO] [stdout] --> src/kafka/tests.rs:520:27 [INFO] [stdout] | [INFO] [stdout] 520 | let _handle = KafkaAckHandle::new( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 523 | (i % 5) as i32, // Distribute across 5 partitions [INFO] [stdout] | -------------- unexpected argument #3 of type `i32` [INFO] [stdout] 524 | i as u64, [INFO] [stdout] | -------- [INFO] [stdout] | | [INFO] [stdout] | unexpected argument #4 of type `u64` [INFO] [stdout] | argument #4 of type `u32` is missing [INFO] [stdout] 525 | 1, [INFO] [stdout] 526 | SystemTime::now(), [INFO] [stdout] | ----------------- argument #6 of type `i64` is missing [INFO] [stdout] | [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/kafka/ack.rs:37:12 [INFO] [stdout] | [INFO] [stdout] 37 | pub fn new( [INFO] [stdout] | ^^^ [INFO] [stdout] ... [INFO] [stdout] 41 | delivery_count: u32, [INFO] [stdout] | ------------------- [INFO] [stdout] 42 | partition: i32, [INFO] [stdout] 43 | offset: i64, [INFO] [stdout] | ----------- [INFO] [stdout] help: did you mean [INFO] [stdout] | [INFO] [stdout] 520 - let _handle = KafkaAckHandle::new( [INFO] [stdout] 521 - format!("message-{}", i), [INFO] [stdout] 522 - "test-topic".to_string(), [INFO] [stdout] 523 - (i % 5) as i32, // Distribute across 5 partitions [INFO] [stdout] 524 - i as u64, [INFO] [stdout] 525 - 1, [INFO] [stdout] 526 - SystemTime::now(), [INFO] [stdout] 527 - ); [INFO] [stdout] 520 + let _handle = KafkaAckHandle::new(format!("message-{}", i), "test-topic".to_string(), SystemTime::now(), /* u32 */, 1, /* i64 */); [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: arguments to this function are incorrect [INFO] [stdout] --> src/kafka/tests.rs:540:22 [INFO] [stdout] | [INFO] [stdout] 540 | let handle = KafkaAckHandle::new( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 543 | 2, [INFO] [stdout] | - expected `std::time::SystemTime`, found `{integer}` [INFO] [stdout] ... [INFO] [stdout] 546 | SystemTime::now(), [INFO] [stdout] | ----------------- expected `i64`, found `std::time::SystemTime` [INFO] [stdout] | [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/kafka/ack.rs:37:12 [INFO] [stdout] | [INFO] [stdout] 37 | pub fn new( [INFO] [stdout] | ^^^ [INFO] [stdout] help: swap these arguments [INFO] [stdout] | [INFO] [stdout] 540 - let handle = KafkaAckHandle::new( [INFO] [stdout] 541 - "perf-test".to_string(), [INFO] [stdout] 542 - "test-topic".to_string(), [INFO] [stdout] 543 - 2, [INFO] [stdout] 544 - 12345, [INFO] [stdout] 545 - 3, [INFO] [stdout] 546 - SystemTime::now(), [INFO] [stdout] 547 - ); [INFO] [stdout] 540 + let handle = KafkaAckHandle::new("perf-test".to_string(), "test-topic".to_string(), SystemTime::now(), 12345, 3, 2); [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: arguments to this function are incorrect [INFO] [stdout] --> src/kafka/tests.rs:574:22 [INFO] [stdout] | [INFO] [stdout] 574 | .map(|i| KafkaAckHandle::new( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 577 | (i % 10) as i32, // 10 partitions [INFO] [stdout] | --------------- unexpected argument #3 of type `i32` [INFO] [stdout] 578 | i as u64, [INFO] [stdout] | -------- [INFO] [stdout] | | [INFO] [stdout] | unexpected argument #4 of type `u64` [INFO] [stdout] | argument #4 of type `u32` is missing [INFO] [stdout] 579 | 1, [INFO] [stdout] 580 | SystemTime::now(), [INFO] [stdout] | ----------------- argument #6 of type `i64` is missing [INFO] [stdout] | [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/kafka/ack.rs:37:12 [INFO] [stdout] | [INFO] [stdout] 37 | pub fn new( [INFO] [stdout] | ^^^ [INFO] [stdout] ... [INFO] [stdout] 41 | delivery_count: u32, [INFO] [stdout] | ------------------- [INFO] [stdout] 42 | partition: i32, [INFO] [stdout] 43 | offset: i64, [INFO] [stdout] | ----------- [INFO] [stdout] help: did you mean [INFO] [stdout] | [INFO] [stdout] 574 - .map(|i| KafkaAckHandle::new( [INFO] [stdout] 575 - format!("message-{}", i), [INFO] [stdout] 576 - "test-topic".to_string(), [INFO] [stdout] 577 - (i % 10) as i32, // 10 partitions [INFO] [stdout] 578 - i as u64, [INFO] [stdout] 579 - 1, [INFO] [stdout] 580 - SystemTime::now(), [INFO] [stdout] 581 - )) [INFO] [stdout] 574 + .map(|i| KafkaAckHandle::new(format!("message-{}", i), "test-topic".to_string(), SystemTime::now(), /* u32 */, 1, /* i64 */)) [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: mismatched types [INFO] [stdout] --> src/kafka/tests.rs:605:68 [INFO] [stdout] | [INFO] [stdout] 605 | assert!(partition_offsets.get(&(i as i32)).unwrap() >= &expected_max); [INFO] [stdout] | ^^^^^^^^^^^^^ expected `&i64`, found `&u64` [INFO] [stdout] | [INFO] [stdout] = note: expected reference `&i64` [INFO] [stdout] found reference `&u64` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: arguments to this function are incorrect [INFO] [stdout] --> src/mqtt/tests.rs:59:26 [INFO] [stdout] | [INFO] [stdout] 59 | let handle = MQTTAckHandle::new( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 62 | qos, [INFO] [stdout] | --- expected `std::time::SystemTime`, found `rumqttc::QoS` [INFO] [stdout] 63 | packet_id, [INFO] [stdout] | --------- expected `u32`, found `std::option::Option<{integer}>` [INFO] [stdout] 64 | delivery_count, [INFO] [stdout] | -------------- expected `rumqttc::QoS`, found `{integer}` [INFO] [stdout] 65 | timestamp, [INFO] [stdout] | --------- expected `std::option::Option`, found `std::time::SystemTime` [INFO] [stdout] | [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/mqtt/ack.rs:37:12 [INFO] [stdout] | [INFO] [stdout] 37 | pub fn new( [INFO] [stdout] | ^^^ [INFO] [stdout] help: reorder these arguments [INFO] [stdout] | [INFO] [stdout] 59 - let handle = MQTTAckHandle::new( [INFO] [stdout] 60 - message_id.clone(), [INFO] [stdout] 61 - topic.clone(), [INFO] [stdout] 62 - qos, [INFO] [stdout] 63 - packet_id, [INFO] [stdout] 64 - delivery_count, [INFO] [stdout] 65 - timestamp, [INFO] [stdout] 66 - ); [INFO] [stdout] 59 + let handle = MQTTAckHandle::new(message_id.clone(), topic.clone(), timestamp, delivery_count, qos, packet_id); [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: arguments to this function are incorrect [INFO] [stdout] --> src/mqtt/tests.rs:94:28 [INFO] [stdout] | [INFO] [stdout] 94 | let handle_retry = MQTTAckHandle::new( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 97 | qos, [INFO] [stdout] | --- expected `std::time::SystemTime`, found `rumqttc::QoS` [INFO] [stdout] 98 | packet_id, [INFO] [stdout] | --------- expected `u32`, found `std::option::Option` [INFO] [stdout] 99 | 2, // delivery_count = 2 [INFO] [stdout] | - expected `rumqttc::QoS`, found `{integer}` [INFO] [stdout] 100 | timestamp, [INFO] [stdout] | --------- expected `std::option::Option`, found `std::time::SystemTime` [INFO] [stdout] | [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/mqtt/ack.rs:37:12 [INFO] [stdout] | [INFO] [stdout] 37 | pub fn new( [INFO] [stdout] | ^^^ [INFO] [stdout] help: reorder these arguments [INFO] [stdout] | [INFO] [stdout] 94 - let handle_retry = MQTTAckHandle::new( [INFO] [stdout] 95 - message_id.clone(), [INFO] [stdout] 96 - topic.clone(), [INFO] [stdout] 97 - qos, [INFO] [stdout] 98 - packet_id, [INFO] [stdout] 99 - 2, // delivery_count = 2 [INFO] [stdout] 100 - timestamp, [INFO] [stdout] 101 - ); [INFO] [stdout] 94 + let handle_retry = MQTTAckHandle::new(message_id.clone(), topic.clone(), timestamp, 2, qos, packet_id); [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: arguments to this function are incorrect [INFO] [stdout] --> src/mqtt/tests.rs:105:37 [INFO] [stdout] | [INFO] [stdout] 105 | let handle_multiple_retry = MQTTAckHandle::new( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 108 | qos, [INFO] [stdout] | --- expected `std::time::SystemTime`, found `rumqttc::QoS` [INFO] [stdout] 109 | packet_id, [INFO] [stdout] | --------- expected `u32`, found `std::option::Option` [INFO] [stdout] 110 | 5, // delivery_count = 5 [INFO] [stdout] | - expected `rumqttc::QoS`, found `{integer}` [INFO] [stdout] 111 | timestamp, [INFO] [stdout] | --------- expected `std::option::Option`, found `std::time::SystemTime` [INFO] [stdout] | [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/mqtt/ack.rs:37:12 [INFO] [stdout] | [INFO] [stdout] 37 | pub fn new( [INFO] [stdout] | ^^^ [INFO] [stdout] help: reorder these arguments [INFO] [stdout] | [INFO] [stdout] 105 - let handle_multiple_retry = MQTTAckHandle::new( [INFO] [stdout] 106 - message_id, [INFO] [stdout] 107 - topic, [INFO] [stdout] 108 - qos, [INFO] [stdout] 109 - packet_id, [INFO] [stdout] 110 - 5, // delivery_count = 5 [INFO] [stdout] 111 - timestamp, [INFO] [stdout] 112 - ); [INFO] [stdout] 105 + let handle_multiple_retry = MQTTAckHandle::new(message_id, topic, timestamp, 5, qos, packet_id); [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: arguments to this function are incorrect [INFO] [stdout] --> src/mqtt/tests.rs:125:23 [INFO] [stdout] | [INFO] [stdout] 125 | let handle1 = MQTTAckHandle::new( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 128 | qos, [INFO] [stdout] | --- expected `std::time::SystemTime`, found `rumqttc::QoS` [INFO] [stdout] 129 | packet_id, [INFO] [stdout] | --------- expected `u32`, found `std::option::Option<{integer}>` [INFO] [stdout] 130 | delivery_count, [INFO] [stdout] | -------------- expected `rumqttc::QoS`, found `{integer}` [INFO] [stdout] 131 | timestamp, [INFO] [stdout] | --------- expected `std::option::Option`, found `std::time::SystemTime` [INFO] [stdout] | [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/mqtt/ack.rs:37:12 [INFO] [stdout] | [INFO] [stdout] 37 | pub fn new( [INFO] [stdout] | ^^^ [INFO] [stdout] help: reorder these arguments [INFO] [stdout] | [INFO] [stdout] 125 - let handle1 = MQTTAckHandle::new( [INFO] [stdout] 126 - message_id.clone(), [INFO] [stdout] 127 - topic.clone(), [INFO] [stdout] 128 - qos, [INFO] [stdout] 129 - packet_id, [INFO] [stdout] 130 - delivery_count, [INFO] [stdout] 131 - timestamp, [INFO] [stdout] 132 - ); [INFO] [stdout] 125 + let handle1 = MQTTAckHandle::new(message_id.clone(), topic.clone(), timestamp, delivery_count, qos, packet_id); [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: arguments to this function are incorrect [INFO] [stdout] --> src/mqtt/tests.rs:134:23 [INFO] [stdout] | [INFO] [stdout] 134 | let handle2 = MQTTAckHandle::new( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 137 | qos, [INFO] [stdout] | --- expected `std::time::SystemTime`, found `rumqttc::QoS` [INFO] [stdout] 138 | packet_id, [INFO] [stdout] | --------- expected `u32`, found `std::option::Option<{integer}>` [INFO] [stdout] 139 | delivery_count, [INFO] [stdout] | -------------- expected `rumqttc::QoS`, found `{integer}` [INFO] [stdout] 140 | timestamp, [INFO] [stdout] | --------- expected `std::option::Option`, found `std::time::SystemTime` [INFO] [stdout] | [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/mqtt/ack.rs:37:12 [INFO] [stdout] | [INFO] [stdout] 37 | pub fn new( [INFO] [stdout] | ^^^ [INFO] [stdout] help: reorder these arguments [INFO] [stdout] | [INFO] [stdout] 134 - let handle2 = MQTTAckHandle::new( [INFO] [stdout] 135 - message_id, [INFO] [stdout] 136 - topic, [INFO] [stdout] 137 - qos, [INFO] [stdout] 138 - packet_id, [INFO] [stdout] 139 - delivery_count, [INFO] [stdout] 140 - timestamp, [INFO] [stdout] 141 - ); [INFO] [stdout] 134 + let handle2 = MQTTAckHandle::new(message_id, topic, timestamp, delivery_count, qos, packet_id); [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: arguments to this function are incorrect [INFO] [stdout] --> src/mqtt/tests.rs:223:28 [INFO] [stdout] | [INFO] [stdout] 223 | let handle_empty = MQTTAckHandle::new( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 226 | QoS::AtMostOnce, [INFO] [stdout] | --------------- expected `std::time::SystemTime`, found `rumqttc::QoS` [INFO] [stdout] 227 | None, [INFO] [stdout] | ---- expected `u32`, found `std::option::Option<_>` [INFO] [stdout] 228 | 0, // Zero delivery count [INFO] [stdout] | - expected `rumqttc::QoS`, found `{integer}` [INFO] [stdout] 229 | timestamp, [INFO] [stdout] | --------- expected `std::option::Option`, found `std::time::SystemTime` [INFO] [stdout] | [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/mqtt/ack.rs:37:12 [INFO] [stdout] | [INFO] [stdout] 37 | pub fn new( [INFO] [stdout] | ^^^ [INFO] [stdout] help: reorder these arguments [INFO] [stdout] | [INFO] [stdout] 223 - let handle_empty = MQTTAckHandle::new( [INFO] [stdout] 224 - "".to_string(), [INFO] [stdout] 225 - "".to_string(), [INFO] [stdout] 226 - QoS::AtMostOnce, [INFO] [stdout] 227 - None, [INFO] [stdout] 228 - 0, // Zero delivery count [INFO] [stdout] 229 - timestamp, [INFO] [stdout] 230 - ); [INFO] [stdout] 223 + let handle_empty = MQTTAckHandle::new("".to_string(), "".to_string(), timestamp, 0, QoS::AtMostOnce, None); [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: arguments to this function are incorrect [INFO] [stdout] --> src/mqtt/tests.rs:239:27 [INFO] [stdout] | [INFO] [stdout] 239 | let handle_long = MQTTAckHandle::new( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 242 | QoS::AtLeastOnce, [INFO] [stdout] | ---------------- expected `std::time::SystemTime`, found `rumqttc::QoS` [INFO] [stdout] 243 | Some(1), [INFO] [stdout] | ------- expected `u32`, found `std::option::Option<{integer}>` [INFO] [stdout] 244 | 1, [INFO] [stdout] | - expected `rumqttc::QoS`, found `{integer}` [INFO] [stdout] 245 | timestamp, [INFO] [stdout] | --------- expected `std::option::Option`, found `std::time::SystemTime` [INFO] [stdout] | [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/mqtt/ack.rs:37:12 [INFO] [stdout] | [INFO] [stdout] 37 | pub fn new( [INFO] [stdout] | ^^^ [INFO] [stdout] help: reorder these arguments [INFO] [stdout] | [INFO] [stdout] 239 - let handle_long = MQTTAckHandle::new( [INFO] [stdout] 240 - "long-topic-test".to_string(), [INFO] [stdout] 241 - long_topic.clone(), [INFO] [stdout] 242 - QoS::AtLeastOnce, [INFO] [stdout] 243 - Some(1), [INFO] [stdout] 244 - 1, [INFO] [stdout] 245 - timestamp, [INFO] [stdout] 246 - ); [INFO] [stdout] 239 + let handle_long = MQTTAckHandle::new("long-topic-test".to_string(), long_topic.clone(), timestamp, 1, QoS::AtLeastOnce, Some(1)); [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: `mqtt::ack::MQTTAckSubscriber` doesn't implement `std::fmt::Debug` [INFO] [stdout] --> src/mqtt/tests.rs:269:28 [INFO] [stdout] | [INFO] [stdout] 269 | let error = result.unwrap_err(); [INFO] [stdout] | ^^^^^^^^^^ the trait `std::fmt::Debug` is not implemented for `mqtt::ack::MQTTAckSubscriber` [INFO] [stdout] | [INFO] [stdout] = note: add `#[derive(Debug)]` to `mqtt::ack::MQTTAckSubscriber` or manually `impl std::fmt::Debug for mqtt::ack::MQTTAckSubscriber` [INFO] [stdout] note: required by a bound in `Result::::unwrap_err` [INFO] [stdout] --> /rustc/1159e78c4747b02ef996e55082b704c09b970588/library/core/src/result.rs:1256:5 [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: arguments to this function are incorrect [INFO] [stdout] --> src/mqtt/tests.rs:428:22 [INFO] [stdout] | [INFO] [stdout] 428 | let handle = MQTTAckHandle::new( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 431 | qos, [INFO] [stdout] | --- expected `std::time::SystemTime`, found `rumqttc::QoS` [INFO] [stdout] 432 | packet_id, [INFO] [stdout] | --------- expected `u32`, found `std::option::Option` [INFO] [stdout] 433 | delivery_count, [INFO] [stdout] | -------------- expected `rumqttc::QoS`, found `u32` [INFO] [stdout] 434 | SystemTime::now(), [INFO] [stdout] | ----------------- expected `std::option::Option`, found `std::time::SystemTime` [INFO] [stdout] | [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/mqtt/ack.rs:37:12 [INFO] [stdout] | [INFO] [stdout] 37 | pub fn new( [INFO] [stdout] | ^^^ [INFO] [stdout] help: reorder these arguments [INFO] [stdout] | [INFO] [stdout] 428 - let handle = MQTTAckHandle::new( [INFO] [stdout] 429 - message.uuid.clone(), [INFO] [stdout] 430 - topic, [INFO] [stdout] 431 - qos, [INFO] [stdout] 432 - packet_id, [INFO] [stdout] 433 - delivery_count, [INFO] [stdout] 434 - SystemTime::now(), [INFO] [stdout] 435 - ); [INFO] [stdout] 428 + let handle = MQTTAckHandle::new(message.uuid.clone(), topic, SystemTime::now(), delivery_count, qos, packet_id); [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: arguments to this function are incorrect [INFO] [stdout] --> src/mqtt/tests.rs:459:26 [INFO] [stdout] | [INFO] [stdout] 459 | let handle = MQTTAckHandle::new( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 462 | qos, [INFO] [stdout] | --- expected `std::time::SystemTime`, found `rumqttc::QoS` [INFO] [stdout] 463 | packet_id, [INFO] [stdout] | --------- expected `u32`, found `std::option::Option<{integer}>` [INFO] [stdout] 464 | delivery_count, [INFO] [stdout] | -------------- expected `rumqttc::QoS`, found `{integer}` [INFO] [stdout] 465 | timestamp, [INFO] [stdout] | --------- expected `std::option::Option`, found `std::time::SystemTime` [INFO] [stdout] | [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/mqtt/ack.rs:37:12 [INFO] [stdout] | [INFO] [stdout] 37 | pub fn new( [INFO] [stdout] | ^^^ [INFO] [stdout] help: reorder these arguments [INFO] [stdout] | [INFO] [stdout] 459 - let handle = MQTTAckHandle::new( [INFO] [stdout] 460 - message_id.clone(), [INFO] [stdout] 461 - topic.clone(), [INFO] [stdout] 462 - qos, [INFO] [stdout] 463 - packet_id, [INFO] [stdout] 464 - delivery_count, [INFO] [stdout] 465 - timestamp, [INFO] [stdout] 466 - ); [INFO] [stdout] 459 + let handle = MQTTAckHandle::new(message_id.clone(), topic.clone(), timestamp, delivery_count, qos, packet_id); [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: arguments to this function are incorrect [INFO] [stdout] --> src/mqtt/tests.rs:514:26 [INFO] [stdout] | [INFO] [stdout] 514 | let handle = MQTTAckHandle::new( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 517 | QoS::AtLeastOnce, [INFO] [stdout] | ---------------- expected `std::time::SystemTime`, found `rumqttc::QoS` [INFO] [stdout] 518 | Some(packet_id), [INFO] [stdout] | --------------- expected `u32`, found `std::option::Option<{integer}>` [INFO] [stdout] 519 | delivery_count, [INFO] [stdout] | -------------- expected `rumqttc::QoS`, found `{integer}` [INFO] [stdout] 520 | timestamp, [INFO] [stdout] | --------- expected `std::option::Option`, found `std::time::SystemTime` [INFO] [stdout] | [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/mqtt/ack.rs:37:12 [INFO] [stdout] | [INFO] [stdout] 37 | pub fn new( [INFO] [stdout] | ^^^ [INFO] [stdout] help: reorder these arguments [INFO] [stdout] | [INFO] [stdout] 514 - let handle = MQTTAckHandle::new( [INFO] [stdout] 515 - message_id.clone(), [INFO] [stdout] 516 - topic.clone(), [INFO] [stdout] 517 - QoS::AtLeastOnce, [INFO] [stdout] 518 - Some(packet_id), [INFO] [stdout] 519 - delivery_count, [INFO] [stdout] 520 - timestamp, [INFO] [stdout] 521 - ); [INFO] [stdout] 514 + let handle = MQTTAckHandle::new(message_id.clone(), topic.clone(), timestamp, delivery_count, QoS::AtLeastOnce, Some(packet_id)); [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: arguments to this function are incorrect [INFO] [stdout] --> src/mqtt/tests.rs:544:26 [INFO] [stdout] | [INFO] [stdout] 544 | let handle = MQTTAckHandle::new( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 547 | qos, [INFO] [stdout] | --- expected `std::time::SystemTime`, found `rumqttc::QoS` [INFO] [stdout] 548 | packet_id, [INFO] [stdout] | --------- expected `u32`, found `std::option::Option<{integer}>` [INFO] [stdout] 549 | count, [INFO] [stdout] | ----- expected `rumqttc::QoS`, found `{integer}` [INFO] [stdout] 550 | SystemTime::now(), [INFO] [stdout] | ----------------- expected `std::option::Option`, found `std::time::SystemTime` [INFO] [stdout] | [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/mqtt/ack.rs:37:12 [INFO] [stdout] | [INFO] [stdout] 37 | pub fn new( [INFO] [stdout] | ^^^ [INFO] [stdout] help: reorder these arguments [INFO] [stdout] | [INFO] [stdout] 544 - let handle = MQTTAckHandle::new( [INFO] [stdout] 545 - message_id.clone(), [INFO] [stdout] 546 - topic.clone(), [INFO] [stdout] 547 - qos, [INFO] [stdout] 548 - packet_id, [INFO] [stdout] 549 - count, [INFO] [stdout] 550 - SystemTime::now(), [INFO] [stdout] 551 - ); [INFO] [stdout] 544 + let handle = MQTTAckHandle::new(message_id.clone(), topic.clone(), SystemTime::now(), count, qos, packet_id); [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: arguments to this function are incorrect [INFO] [stdout] --> src/mqtt/tests.rs:606:27 [INFO] [stdout] | [INFO] [stdout] 606 | let _handle = MQTTAckHandle::new( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 609 | qos, [INFO] [stdout] | --- expected `std::time::SystemTime`, found `rumqttc::QoS` [INFO] [stdout] 610 | packet_id, [INFO] [stdout] | --------- expected `u32`, found `std::option::Option` [INFO] [stdout] 611 | 1, [INFO] [stdout] | - expected `rumqttc::QoS`, found `{integer}` [INFO] [stdout] 612 | SystemTime::now(), [INFO] [stdout] | ----------------- expected `std::option::Option`, found `std::time::SystemTime` [INFO] [stdout] | [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/mqtt/ack.rs:37:12 [INFO] [stdout] | [INFO] [stdout] 37 | pub fn new( [INFO] [stdout] | ^^^ [INFO] [stdout] help: reorder these arguments [INFO] [stdout] | [INFO] [stdout] 606 - let _handle = MQTTAckHandle::new( [INFO] [stdout] 607 - format!("message-{}", i), [INFO] [stdout] 608 - format!("topic/{}", i % 10), [INFO] [stdout] 609 - qos, [INFO] [stdout] 610 - packet_id, [INFO] [stdout] 611 - 1, [INFO] [stdout] 612 - SystemTime::now(), [INFO] [stdout] 613 - ); [INFO] [stdout] 606 + let _handle = MQTTAckHandle::new(format!("message-{}", i), format!("topic/{}", i % 10), SystemTime::now(), 1, qos, packet_id); [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: arguments to this function are incorrect [INFO] [stdout] --> src/rabbitmq/tests.rs:25:22 [INFO] [stdout] | [INFO] [stdout] 25 | let handle = RabbitMQAckHandle::new( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 28 | delivery_tag, [INFO] [stdout] | ------------ expected `std::time::SystemTime`, found `{integer}` [INFO] [stdout] 29 | delivery_count, [INFO] [stdout] 30 | timestamp, [INFO] [stdout] | --------- expected `u64`, found `std::time::SystemTime` [INFO] [stdout] | [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/rabbitmq/ack.rs:34:12 [INFO] [stdout] | [INFO] [stdout] 34 | pub fn new( [INFO] [stdout] | ^^^ [INFO] [stdout] help: swap these arguments [INFO] [stdout] | [INFO] [stdout] 25 - let handle = RabbitMQAckHandle::new( [INFO] [stdout] 26 - message_id.clone(), [INFO] [stdout] 27 - topic.clone(), [INFO] [stdout] 28 - delivery_tag, [INFO] [stdout] 29 - delivery_count, [INFO] [stdout] 30 - timestamp, [INFO] [stdout] 31 - ); [INFO] [stdout] 25 + let handle = RabbitMQAckHandle::new(message_id.clone(), topic.clone(), timestamp, delivery_count, delivery_tag); [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: arguments to this function are incorrect [INFO] [stdout] --> src/rabbitmq/tests.rs:49:28 [INFO] [stdout] | [INFO] [stdout] 49 | let handle_first = RabbitMQAckHandle::new( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 52 | delivery_tag, [INFO] [stdout] | ------------ expected `std::time::SystemTime`, found `{integer}` [INFO] [stdout] 53 | 1, // delivery_count = 1 [INFO] [stdout] 54 | timestamp, [INFO] [stdout] | --------- expected `u64`, found `std::time::SystemTime` [INFO] [stdout] | [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/rabbitmq/ack.rs:34:12 [INFO] [stdout] | [INFO] [stdout] 34 | pub fn new( [INFO] [stdout] | ^^^ [INFO] [stdout] help: swap these arguments [INFO] [stdout] | [INFO] [stdout] 49 - let handle_first = RabbitMQAckHandle::new( [INFO] [stdout] 50 - message_id.clone(), [INFO] [stdout] 51 - topic.clone(), [INFO] [stdout] 52 - delivery_tag, [INFO] [stdout] 53 - 1, // delivery_count = 1 [INFO] [stdout] 54 - timestamp, [INFO] [stdout] 55 - ); [INFO] [stdout] 49 + let handle_first = RabbitMQAckHandle::new(message_id.clone(), topic.clone(), timestamp, 1, delivery_tag); [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: arguments to this function are incorrect [INFO] [stdout] --> src/rabbitmq/tests.rs:59:28 [INFO] [stdout] | [INFO] [stdout] 59 | let handle_retry = RabbitMQAckHandle::new( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 62 | delivery_tag, [INFO] [stdout] | ------------ expected `std::time::SystemTime`, found `{integer}` [INFO] [stdout] 63 | 2, // delivery_count = 2 [INFO] [stdout] 64 | timestamp, [INFO] [stdout] | --------- expected `u64`, found `std::time::SystemTime` [INFO] [stdout] | [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/rabbitmq/ack.rs:34:12 [INFO] [stdout] | [INFO] [stdout] 34 | pub fn new( [INFO] [stdout] | ^^^ [INFO] [stdout] help: swap these arguments [INFO] [stdout] | [INFO] [stdout] 59 - let handle_retry = RabbitMQAckHandle::new( [INFO] [stdout] 60 - message_id.clone(), [INFO] [stdout] 61 - topic.clone(), [INFO] [stdout] 62 - delivery_tag, [INFO] [stdout] 63 - 2, // delivery_count = 2 [INFO] [stdout] 64 - timestamp, [INFO] [stdout] 65 - ); [INFO] [stdout] 59 + let handle_retry = RabbitMQAckHandle::new(message_id.clone(), topic.clone(), timestamp, 2, delivery_tag); [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: arguments to this function are incorrect [INFO] [stdout] --> src/rabbitmq/tests.rs:69:37 [INFO] [stdout] | [INFO] [stdout] 69 | let handle_multiple_retry = RabbitMQAckHandle::new( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 72 | delivery_tag, [INFO] [stdout] | ------------ expected `std::time::SystemTime`, found `{integer}` [INFO] [stdout] 73 | 5, // delivery_count = 5 [INFO] [stdout] 74 | timestamp, [INFO] [stdout] | --------- expected `u64`, found `std::time::SystemTime` [INFO] [stdout] | [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/rabbitmq/ack.rs:34:12 [INFO] [stdout] | [INFO] [stdout] 34 | pub fn new( [INFO] [stdout] | ^^^ [INFO] [stdout] help: swap these arguments [INFO] [stdout] | [INFO] [stdout] 69 - let handle_multiple_retry = RabbitMQAckHandle::new( [INFO] [stdout] 70 - message_id, [INFO] [stdout] 71 - topic, [INFO] [stdout] 72 - delivery_tag, [INFO] [stdout] 73 - 5, // delivery_count = 5 [INFO] [stdout] 74 - timestamp, [INFO] [stdout] 75 - ); [INFO] [stdout] 69 + let handle_multiple_retry = RabbitMQAckHandle::new(message_id, topic, timestamp, 5, delivery_tag); [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: arguments to this function are incorrect [INFO] [stdout] --> src/rabbitmq/tests.rs:87:23 [INFO] [stdout] | [INFO] [stdout] 87 | let handle1 = RabbitMQAckHandle::new( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 90 | delivery_tag, [INFO] [stdout] | ------------ expected `std::time::SystemTime`, found `{integer}` [INFO] [stdout] 91 | delivery_count, [INFO] [stdout] 92 | timestamp, [INFO] [stdout] | --------- expected `u64`, found `std::time::SystemTime` [INFO] [stdout] | [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/rabbitmq/ack.rs:34:12 [INFO] [stdout] | [INFO] [stdout] 34 | pub fn new( [INFO] [stdout] | ^^^ [INFO] [stdout] help: swap these arguments [INFO] [stdout] | [INFO] [stdout] 87 - let handle1 = RabbitMQAckHandle::new( [INFO] [stdout] 88 - message_id.clone(), [INFO] [stdout] 89 - topic.clone(), [INFO] [stdout] 90 - delivery_tag, [INFO] [stdout] 91 - delivery_count, [INFO] [stdout] 92 - timestamp, [INFO] [stdout] 93 - ); [INFO] [stdout] 87 + let handle1 = RabbitMQAckHandle::new(message_id.clone(), topic.clone(), timestamp, delivery_count, delivery_tag); [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: arguments to this function are incorrect [INFO] [stdout] --> src/rabbitmq/tests.rs:95:23 [INFO] [stdout] | [INFO] [stdout] 95 | let handle2 = RabbitMQAckHandle::new( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 98 | delivery_tag, [INFO] [stdout] | ------------ expected `std::time::SystemTime`, found `{integer}` [INFO] [stdout] 99 | delivery_count, [INFO] [stdout] 100 | timestamp, [INFO] [stdout] | --------- expected `u64`, found `std::time::SystemTime` [INFO] [stdout] | [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/rabbitmq/ack.rs:34:12 [INFO] [stdout] | [INFO] [stdout] 34 | pub fn new( [INFO] [stdout] | ^^^ [INFO] [stdout] help: swap these arguments [INFO] [stdout] | [INFO] [stdout] 95 - let handle2 = RabbitMQAckHandle::new( [INFO] [stdout] 96 - message_id, [INFO] [stdout] 97 - topic, [INFO] [stdout] 98 - delivery_tag, [INFO] [stdout] 99 - delivery_count, [INFO] [stdout] 100 - timestamp, [INFO] [stdout] 101 - ); [INFO] [stdout] 95 + let handle2 = RabbitMQAckHandle::new(message_id, topic, timestamp, delivery_count, delivery_tag); [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: arguments to this function are incorrect [INFO] [stdout] --> src/rabbitmq/tests.rs:115:22 [INFO] [stdout] | [INFO] [stdout] 115 | let handle = RabbitMQAckHandle::new( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 118 | delivery_tag, [INFO] [stdout] | ------------ expected `std::time::SystemTime`, found `{integer}` [INFO] [stdout] 119 | delivery_count, [INFO] [stdout] 120 | timestamp, [INFO] [stdout] | --------- expected `u64`, found `std::time::SystemTime` [INFO] [stdout] | [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/rabbitmq/ack.rs:34:12 [INFO] [stdout] | [INFO] [stdout] 34 | pub fn new( [INFO] [stdout] | ^^^ [INFO] [stdout] help: swap these arguments [INFO] [stdout] | [INFO] [stdout] 115 - let handle = RabbitMQAckHandle::new( [INFO] [stdout] 116 - message_id.clone(), [INFO] [stdout] 117 - topic.clone(), [INFO] [stdout] 118 - delivery_tag, [INFO] [stdout] 119 - delivery_count, [INFO] [stdout] 120 - timestamp, [INFO] [stdout] 121 - ); [INFO] [stdout] 115 + let handle = RabbitMQAckHandle::new(message_id.clone(), topic.clone(), timestamp, delivery_count, delivery_tag); [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: arguments to this function are incorrect [INFO] [stdout] --> src/rabbitmq/tests.rs:143:22 [INFO] [stdout] | [INFO] [stdout] 143 | let handle = RabbitMQAckHandle::new( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 146 | delivery_tag, [INFO] [stdout] | ------------ expected `std::time::SystemTime`, found `{integer}` [INFO] [stdout] 147 | delivery_count, [INFO] [stdout] 148 | timestamp, [INFO] [stdout] | --------- expected `u64`, found `std::time::SystemTime` [INFO] [stdout] | [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/rabbitmq/ack.rs:34:12 [INFO] [stdout] | [INFO] [stdout] 34 | pub fn new( [INFO] [stdout] | ^^^ [INFO] [stdout] help: swap these arguments [INFO] [stdout] | [INFO] [stdout] 143 - let handle = RabbitMQAckHandle::new( [INFO] [stdout] 144 - message_id.clone(), [INFO] [stdout] 145 - topic.clone(), [INFO] [stdout] 146 - delivery_tag, [INFO] [stdout] 147 - delivery_count, [INFO] [stdout] 148 - timestamp, [INFO] [stdout] 149 - ); [INFO] [stdout] 143 + let handle = RabbitMQAckHandle::new(message_id.clone(), topic.clone(), timestamp, delivery_count, delivery_tag); [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: `rabbitmq::ack::RabbitMQAckSubscriber` doesn't implement `std::fmt::Debug` [INFO] [stdout] --> src/rabbitmq/tests.rs:175:28 [INFO] [stdout] | [INFO] [stdout] 175 | let error = result.unwrap_err(); [INFO] [stdout] | ^^^^^^^^^^ the trait `std::fmt::Debug` is not implemented for `rabbitmq::ack::RabbitMQAckSubscriber` [INFO] [stdout] | [INFO] [stdout] = note: add `#[derive(Debug)]` to `rabbitmq::ack::RabbitMQAckSubscriber` or manually `impl std::fmt::Debug for rabbitmq::ack::RabbitMQAckSubscriber` [INFO] [stdout] note: required by a bound in `Result::::unwrap_err` [INFO] [stdout] --> /rustc/1159e78c4747b02ef996e55082b704c09b970588/library/core/src/result.rs:1256:5 [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0061]: this function takes 5 arguments but 3 arguments were supplied [INFO] [stdout] --> src/rabbitmq/tests.rs:286:22 [INFO] [stdout] | [INFO] [stdout] 286 | let handle = RabbitMQAckHandle::new(message.uuid.clone(), queue_name, SystemTime::now(, delivery_count, delivery_tag), [INFO] [stdout] | ______________________^^^^^^^^^^^^^^^^^^^^^^- [INFO] [stdout] 287 | | ); [INFO] [stdout] | |_________- two arguments of type `u32` and `u64` are missing [INFO] [stdout] | [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/rabbitmq/ack.rs:34:12 [INFO] [stdout] | [INFO] [stdout] 34 | pub fn new( [INFO] [stdout] | ^^^ [INFO] [stdout] ... [INFO] [stdout] 38 | delivery_count: u32, [INFO] [stdout] | ------------------- [INFO] [stdout] 39 | delivery_tag: u64, [INFO] [stdout] | ----------------- [INFO] [stdout] help: provide the arguments [INFO] [stdout] | [INFO] [stdout] 286 - let handle = RabbitMQAckHandle::new(message.uuid.clone(), queue_name, SystemTime::now(, delivery_count, delivery_tag), [INFO] [stdout] 287 - ); [INFO] [stdout] 286 + let handle = RabbitMQAckHandle::new(message.uuid.clone(), queue_name, SystemTime::now(, delivery_count, delivery_tag), /* u32 */, /* u64 */); [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0061]: this function takes 5 arguments but 3 arguments were supplied [INFO] [stdout] --> src/rabbitmq/tests.rs:334:26 [INFO] [stdout] | [INFO] [stdout] 334 | let handle = RabbitMQAckHandle::new(message_id.clone(), queue.clone(), SystemTime::now(, count, delivery_tag), [INFO] [stdout] | __________________________^^^^^^^^^^^^^^^^^^^^^^- [INFO] [stdout] 335 | | ); [INFO] [stdout] | |_____________- two arguments of type `u32` and `u64` are missing [INFO] [stdout] | [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/rabbitmq/ack.rs:34:12 [INFO] [stdout] | [INFO] [stdout] 34 | pub fn new( [INFO] [stdout] | ^^^ [INFO] [stdout] ... [INFO] [stdout] 38 | delivery_count: u32, [INFO] [stdout] | ------------------- [INFO] [stdout] 39 | delivery_tag: u64, [INFO] [stdout] | ----------------- [INFO] [stdout] help: provide the arguments [INFO] [stdout] | [INFO] [stdout] 334 - let handle = RabbitMQAckHandle::new(message_id.clone(), queue.clone(), SystemTime::now(, count, delivery_tag), [INFO] [stdout] 335 - ); [INFO] [stdout] 334 + let handle = RabbitMQAckHandle::new(message_id.clone(), queue.clone(), SystemTime::now(, count, delivery_tag), /* u32 */, /* u64 */); [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: arguments to this function are incorrect [INFO] [stdout] --> src/rabbitmq/tests.rs:352:22 [INFO] [stdout] | [INFO] [stdout] 352 | let handle = RabbitMQAckHandle::new( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 355 | delivery_tag, [INFO] [stdout] | ------------ expected `std::time::SystemTime`, found `{integer}` [INFO] [stdout] 356 | delivery_count, [INFO] [stdout] 357 | timestamp, [INFO] [stdout] | --------- expected `u64`, found `std::time::SystemTime` [INFO] [stdout] | [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/rabbitmq/ack.rs:34:12 [INFO] [stdout] | [INFO] [stdout] 34 | pub fn new( [INFO] [stdout] | ^^^ [INFO] [stdout] help: swap these arguments [INFO] [stdout] | [INFO] [stdout] 352 - let handle = RabbitMQAckHandle::new( [INFO] [stdout] 353 - message_id.clone(), [INFO] [stdout] 354 - queue.clone(), [INFO] [stdout] 355 - delivery_tag, [INFO] [stdout] 356 - delivery_count, [INFO] [stdout] 357 - timestamp, [INFO] [stdout] 358 - ); [INFO] [stdout] 352 + let handle = RabbitMQAckHandle::new(message_id.clone(), queue.clone(), timestamp, delivery_count, delivery_tag); [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: arguments to this function are incorrect [INFO] [stdout] --> src/rabbitmq/tests.rs:387:27 [INFO] [stdout] | [INFO] [stdout] 387 | let _handle = RabbitMQAckHandle::new( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 390 | i as u64, [INFO] [stdout] | -------- expected `std::time::SystemTime`, found `u64` [INFO] [stdout] 391 | 1, [INFO] [stdout] 392 | SystemTime::now(), [INFO] [stdout] | ----------------- expected `u64`, found `std::time::SystemTime` [INFO] [stdout] | [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/rabbitmq/ack.rs:34:12 [INFO] [stdout] | [INFO] [stdout] 34 | pub fn new( [INFO] [stdout] | ^^^ [INFO] [stdout] help: swap these arguments [INFO] [stdout] | [INFO] [stdout] 387 - let _handle = RabbitMQAckHandle::new( [INFO] [stdout] 388 - format!("message-{}", i), [INFO] [stdout] 389 - "test-queue".to_string(), [INFO] [stdout] 390 - i as u64, [INFO] [stdout] 391 - 1, [INFO] [stdout] 392 - SystemTime::now(), [INFO] [stdout] 393 - ); [INFO] [stdout] 387 + let _handle = RabbitMQAckHandle::new(format!("message-{}", i), "test-queue".to_string(), SystemTime::now(), 1, i as u64); [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: arguments to this function are incorrect [INFO] [stdout] --> src/rabbitmq/tests.rs:434:22 [INFO] [stdout] | [INFO] [stdout] 434 | .map(|i| RabbitMQAckHandle::new( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 437 | i as u64, [INFO] [stdout] | -------- expected `std::time::SystemTime`, found `u64` [INFO] [stdout] 438 | 1, [INFO] [stdout] 439 | SystemTime::now(), [INFO] [stdout] | ----------------- expected `u64`, found `std::time::SystemTime` [INFO] [stdout] | [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/rabbitmq/ack.rs:34:12 [INFO] [stdout] | [INFO] [stdout] 34 | pub fn new( [INFO] [stdout] | ^^^ [INFO] [stdout] help: swap these arguments [INFO] [stdout] | [INFO] [stdout] 434 - .map(|i| RabbitMQAckHandle::new( [INFO] [stdout] 435 - format!("message-{}", i), [INFO] [stdout] 436 - "test-queue".to_string(), [INFO] [stdout] 437 - i as u64, [INFO] [stdout] 438 - 1, [INFO] [stdout] 439 - SystemTime::now(), [INFO] [stdout] 440 - )) [INFO] [stdout] 434 + .map(|i| RabbitMQAckHandle::new(format!("message-{}", i), "test-queue".to_string(), SystemTime::now(), 1, i as u64)) [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> src/memory/advanced_tests.rs:80:13 [INFO] [stdout] | [INFO] [stdout] 80 | let mut subscriber = InMemorySubscriber::new(broker.clone()); [INFO] [stdout] | ----^^^^^^^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_mut)]` on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> src/memory/advanced_tests.rs:184:13 [INFO] [stdout] | [INFO] [stdout] 184 | let mut subscriber = InMemorySubscriber::new(broker.clone()); [INFO] [stdout] | ----^^^^^^^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> src/memory/advanced_tests.rs:235:13 [INFO] [stdout] | [INFO] [stdout] 235 | let mut subscriber1 = InMemorySubscriber::new(broker.clone()); [INFO] [stdout] | ----^^^^^^^^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> src/memory/advanced_tests.rs:236:13 [INFO] [stdout] | [INFO] [stdout] 236 | let mut subscriber2 = InMemorySubscriber::new(broker.clone()); [INFO] [stdout] | ----^^^^^^^^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> src/memory/example.rs:122:13 [INFO] [stdout] | [INFO] [stdout] 122 | let mut subscriber = InMemorySubscriber::new(broker.clone()); [INFO] [stdout] | ----^^^^^^^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> src/memory/example.rs:170:13 [INFO] [stdout] | [INFO] [stdout] 170 | let mut subscriber = InMemorySubscriber::new(broker.clone()); [INFO] [stdout] | ----^^^^^^^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `start_time` [INFO] [stdout] --> src/memory/publisher.rs:66:13 [INFO] [stdout] | [INFO] [stdout] 66 | let start_time = Instant::now(); [INFO] [stdout] | ^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_start_time` [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_variables)]` on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> src/memory/subscriber.rs:264:13 [INFO] [stdout] | [INFO] [stdout] 264 | let mut subscriber = InMemorySubscriber::new(broker.clone()); [INFO] [stdout] | ----^^^^^^^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> src/memory/subscriber.rs:345:13 [INFO] [stdout] | [INFO] [stdout] 345 | let mut subscriber = InMemorySubscriber::new(broker.clone()); [INFO] [stdout] | ----^^^^^^^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> src/memory/subscriber.rs:370:13 [INFO] [stdout] | [INFO] [stdout] 370 | let mut subscriber = InMemorySubscriber::new(broker.clone()); [INFO] [stdout] | ----^^^^^^^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> src/memory/subscriber.rs:397:13 [INFO] [stdout] | [INFO] [stdout] 397 | let mut subscriber = InMemorySubscriber::new(broker.clone()); [INFO] [stdout] | ----^^^^^^^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> src/memory/subscriber.rs:413:13 [INFO] [stdout] | [INFO] [stdout] 413 | let mut subscriber = InMemorySubscriber::new(broker.clone()); [INFO] [stdout] | ----^^^^^^^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> src/memory/subscriber.rs:435:13 [INFO] [stdout] | [INFO] [stdout] 435 | let mut subscriber = InMemorySubscriber::new(broker); [INFO] [stdout] | ----^^^^^^^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> src/memory/subscriber.rs:449:13 [INFO] [stdout] | [INFO] [stdout] 449 | let mut subscriber = InMemorySubscriber::new(broker.clone()); [INFO] [stdout] | ----^^^^^^^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: field `broker` is never read [INFO] [stdout] --> src/memory/ack_fixed.rs:27:5 [INFO] [stdout] | [INFO] [stdout] 17 | pub struct InMemoryAckHandleFixed { [INFO] [stdout] | ---------------------- field in this struct [INFO] [stdout] ... [INFO] [stdout] 27 | broker: Weak, [INFO] [stdout] | ^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `InMemoryAckHandleFixed` has derived impls for the traits `Clone` and `Debug`, but these are intentionally ignored during dead code analysis [INFO] [stdout] = note: `#[warn(dead_code)]` on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: method `remove_subscriber` is never used [INFO] [stdout] --> src/memory/broker.rs:120:8 [INFO] [stdout] | [INFO] [stdout] 30 | impl TopicData { [INFO] [stdout] | -------------- method in this implementation [INFO] [stdout] ... [INFO] [stdout] 120 | fn remove_subscriber(&mut self, sender_id: &mpsc::UnboundedSender) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: method `estimate_memory_usage` is never used [INFO] [stdout] --> src/memory/broker.rs:544:8 [INFO] [stdout] | [INFO] [stdout] 172 | impl InMemoryBroker { [INFO] [stdout] | ------------------- method in this implementation [INFO] [stdout] ... [INFO] [stdout] 544 | fn estimate_memory_usage(&self) -> usize { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: field `event_loop` is never read [INFO] [stdout] --> src/mqtt/ack.rs:103:5 [INFO] [stdout] | [INFO] [stdout] 99 | pub struct MQTTAckSubscriber { [INFO] [stdout] | ----------------- field in this struct [INFO] [stdout] ... [INFO] [stdout] 103 | event_loop: Arc>, [INFO] [stdout] | ^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated function `handle_event_loop` is never used [INFO] [stdout] --> src/mqtt/ack.rs:223:14 [INFO] [stdout] | [INFO] [stdout] 122 | impl MQTTAckSubscriber { [INFO] [stdout] | ---------------------- associated function in this implementation [INFO] [stdout] ... [INFO] [stdout] 223 | async fn handle_event_loop( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] Some errors have detailed explanations: E0061, E0277, E0308. [INFO] [stdout] [INFO] [stdout] For more information about an error, try `rustc --explain E0061`. [INFO] [stdout] [INFO] [stderr] error: could not compile `kincir` (lib test) due to 72 previous errors; 21 warnings emitted [INFO] [stderr] warning: build failed, waiting for other jobs to finish... [INFO] running `Command { std: "docker" "inspect" "32fd46a3d10a53eb828b428a4f77f9ec842f73d6436ab32dac341485886b28fa", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "32fd46a3d10a53eb828b428a4f77f9ec842f73d6436ab32dac341485886b28fa", kill_on_drop: false }` [INFO] [stdout] 32fd46a3d10a53eb828b428a4f77f9ec842f73d6436ab32dac341485886b28fa