[INFO] fetching crate kincir 0.2.0... [INFO] testing kincir-0.2.0 against master#cdb45c87e2cd43495379f7e867e3cc15dcee9f93 for pr-145838-1 [INFO] extracting crate kincir 0.2.0 into /workspace/builds/worker-6-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-6-tc1/source/Cargo.toml [INFO] validating manifest of crates.io crate kincir 0.2.0 on toolchain cdb45c87e2cd43495379f7e867e3cc15dcee9f93 [INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+cdb45c87e2cd43495379f7e867e3cc15dcee9f93" "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" "+cdb45c87e2cd43495379f7e867e3cc15dcee9f93" "fetch" "--manifest-path" "Cargo.toml", kill_on_drop: false }` [INFO] [stderr] Updating crates.io index [INFO] [stderr] Blocking waiting for file lock on package cache [INFO] [stderr] Downloading crates ... [INFO] [stderr] Downloaded tokio-amqp v2.0.0 [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-6-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-6-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:7ad1b28ee6f5f7f699f6cf7015098d6ccdd96d6f2d78dd06228f5b4c9faf309c" "/opt/rustwide/cargo-home/bin/cargo" "+cdb45c87e2cd43495379f7e867e3cc15dcee9f93" "metadata" "--no-deps" "--format-version=1", kill_on_drop: false }` [INFO] [stdout] d7868cd3bec3fddfc23a3bf641091f0e8a90ba2fe603ec842b233ced7939301a [INFO] running `Command { std: "docker" "start" "-a" "d7868cd3bec3fddfc23a3bf641091f0e8a90ba2fe603ec842b233ced7939301a", kill_on_drop: false }` [INFO] running `Command { std: "docker" "inspect" "d7868cd3bec3fddfc23a3bf641091f0e8a90ba2fe603ec842b233ced7939301a", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "d7868cd3bec3fddfc23a3bf641091f0e8a90ba2fe603ec842b233ced7939301a", kill_on_drop: false }` [INFO] [stdout] d7868cd3bec3fddfc23a3bf641091f0e8a90ba2fe603ec842b233ced7939301a [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-6-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-6-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=forbid" "-e" "RUSTDOCFLAGS=--cap-lints=forbid" "-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:7ad1b28ee6f5f7f699f6cf7015098d6ccdd96d6f2d78dd06228f5b4c9faf309c" "/opt/rustwide/cargo-home/bin/cargo" "+cdb45c87e2cd43495379f7e867e3cc15dcee9f93" "build" "--frozen" "--message-format=json", kill_on_drop: false }` [INFO] [stdout] f9363270f775cf54d03f4d78d2b0d212a000ffba083e4e9125da3fdbfca1d87d [INFO] running `Command { std: "docker" "start" "-a" "f9363270f775cf54d03f4d78d2b0d212a000ffba083e4e9125da3fdbfca1d87d", kill_on_drop: false }` [INFO] [stderr] Compiling syn v2.0.104 [INFO] [stderr] Compiling crossbeam-utils v0.8.21 [INFO] [stderr] Compiling cc v1.2.30 [INFO] [stderr] Compiling getrandom v0.2.16 [INFO] [stderr] Compiling base64ct v1.8.0 [INFO] [stderr] Compiling const-oid v0.9.6 [INFO] [stderr] Compiling time-core v0.1.4 [INFO] [stderr] Compiling flagset v0.4.7 [INFO] [stderr] Compiling parking_lot_core v0.9.11 [INFO] [stderr] Compiling block-padding v0.3.3 [INFO] [stderr] Compiling deranged v0.4.0 [INFO] [stderr] Compiling digest v0.10.7 [INFO] [stderr] Compiling getrandom v0.3.3 [INFO] [stderr] Compiling rusticata-macros v4.1.0 [INFO] [stderr] Compiling serde_json v1.0.141 [INFO] [stderr] Compiling oid-registry v0.8.1 [INFO] [stderr] Compiling time-macros v0.2.22 [INFO] [stderr] Compiling inout v0.1.4 [INFO] [stderr] Compiling num-bigint v0.4.6 [INFO] [stderr] Compiling hmac v0.12.1 [INFO] [stderr] Compiling sha2 v0.10.9 [INFO] [stderr] Compiling socket2 v0.5.10 [INFO] [stderr] Compiling rustls-pemfile v2.2.0 [INFO] [stderr] Compiling cipher v0.4.4 [INFO] [stderr] Compiling pem-rfc7468 v0.7.0 [INFO] [stderr] Compiling parking_lot v0.12.4 [INFO] [stderr] Compiling pbkdf2 v0.12.2 [INFO] [stderr] Compiling rand_core v0.9.3 [INFO] [stderr] Compiling rustls v0.23.29 [INFO] [stderr] Compiling rustls-native-certs v0.7.3 [INFO] [stderr] Compiling concurrent-queue v2.5.0 [INFO] [stderr] Compiling futures-lite v2.6.0 [INFO] [stderr] Compiling data-encoding v2.9.0 [INFO] [stderr] Compiling io-lifetimes v1.0.11 [INFO] [stderr] Compiling salsa20 v0.10.2 [INFO] [stderr] Compiling cbc v0.1.2 [INFO] [stderr] Compiling scrypt v0.11.0 [INFO] [stderr] Compiling aes v0.8.4 [INFO] [stderr] Compiling rand_chacha v0.9.0 [INFO] [stderr] Compiling des v0.8.1 [INFO] [stderr] Compiling rc2 v0.8.1 [INFO] [stderr] Compiling event-listener v5.4.0 [INFO] [stderr] Compiling rustix v1.0.8 [INFO] [stderr] Compiling sha1 v0.10.6 [INFO] [stderr] Compiling cookie-factory v0.3.3 [INFO] [stderr] Compiling rustix v0.37.28 [INFO] [stderr] Compiling event-listener-strategy v0.5.4 [INFO] [stderr] Compiling async-io v1.13.0 [INFO] [stderr] Compiling linux-raw-sys v0.3.8 [INFO] [stderr] Compiling async-lock v2.8.0 [INFO] [stderr] Compiling rand v0.9.2 [INFO] [stderr] Compiling async-channel v2.5.0 [INFO] [stderr] Compiling async-lock v3.4.0 [INFO] [stderr] Compiling async-executor v1.13.2 [INFO] [stderr] Compiling blocking v1.6.2 [INFO] [stderr] Compiling flume v0.11.1 [INFO] [stderr] Compiling polling v2.8.0 [INFO] [stderr] Compiling socket2 v0.4.10 [INFO] [stderr] Compiling amq-protocol v7.2.3 [INFO] [stderr] Compiling rustls v0.22.4 [INFO] [stderr] Compiling time v0.3.41 [INFO] [stderr] Compiling rdkafka-sys v4.9.0+2.10.0 [INFO] [stderr] Compiling lapin v2.5.4 [INFO] [stderr] Compiling uuid v1.17.0 [INFO] [stderr] Compiling ring v0.17.14 [INFO] [stderr] Compiling libz-sys v1.1.22 [INFO] [stderr] Compiling polling v3.9.0 [INFO] [stderr] Compiling synstructure v0.13.2 [INFO] [stderr] Compiling async-io v2.5.0 [INFO] [stderr] Compiling async-global-executor v3.1.0 [INFO] [stderr] Compiling displaydoc v0.2.5 [INFO] [stderr] Compiling zerofrom-derive v0.1.6 [INFO] [stderr] Compiling yoke-derive v0.8.0 [INFO] [stderr] Compiling zerovec-derive v0.11.1 [INFO] [stderr] Compiling der_derive v0.7.3 [INFO] [stderr] Compiling thiserror-impl v2.0.12 [INFO] [stderr] Compiling asn1-rs-derive v0.6.0 [INFO] [stderr] Compiling serde_derive v1.0.219 [INFO] [stderr] Compiling asn1-rs-impl v0.2.0 [INFO] [stderr] Compiling tokio-macros v2.5.0 [INFO] [stderr] Compiling async-trait v0.1.88 [INFO] [stderr] Compiling tracing-attributes v0.1.30 [INFO] [stderr] Compiling futures-macro v0.3.31 [INFO] [stderr] Compiling rustls-webpki v0.103.4 [INFO] [stderr] Compiling rustls-webpki v0.102.8 [INFO] [stderr] Compiling tokio v1.46.1 [INFO] [stderr] Compiling num_enum_derive v0.7.4 [INFO] [stderr] Compiling reactor-trait v1.1.0 [INFO] [stderr] Compiling futures-util v0.3.31 [INFO] [stderr] Compiling executor-trait v2.1.2 [INFO] [stderr] Compiling async-global-executor-trait v2.2.0 [INFO] [stderr] Compiling async-reactor-trait v1.1.0 [INFO] [stderr] Compiling thiserror-impl v1.0.69 [INFO] [stderr] Compiling der v0.7.10 [INFO] [stderr] Compiling tracing v0.1.41 [INFO] [stderr] Compiling pinky-swear v6.2.0 [INFO] [stderr] Compiling thiserror v2.0.12 [INFO] [stderr] Compiling num_enum v0.7.4 [INFO] [stderr] Compiling asn1-rs v0.7.1 [INFO] [stderr] Compiling spki v0.7.3 [INFO] [stderr] Compiling zerofrom v0.1.6 [INFO] [stderr] Compiling x509-cert v0.2.5 [INFO] [stderr] Compiling yoke v0.8.0 [INFO] [stderr] Compiling pkcs5 v0.7.1 [INFO] [stderr] Compiling zerovec v0.11.2 [INFO] [stderr] Compiling zerotrie v0.2.2 [INFO] [stderr] Compiling thiserror v1.0.69 [INFO] [stderr] Compiling tinystr v0.8.1 [INFO] [stderr] Compiling icu_locale_core v2.0.0 [INFO] [stderr] Compiling potential_utf v0.1.2 [INFO] [stderr] Compiling icu_collections v2.0.0 [INFO] [stderr] Compiling serde v1.0.219 [INFO] [stderr] Compiling cms v0.2.3 [INFO] [stderr] Compiling icu_provider v2.0.0 [INFO] [stderr] Compiling der-parser v10.0.0 [INFO] [stderr] Compiling icu_normalizer v2.0.0 [INFO] [stderr] Compiling icu_properties v2.0.1 [INFO] [stderr] Compiling pkcs12 v0.1.0 [INFO] [stderr] Compiling futures-executor v0.3.31 [INFO] [stderr] Compiling futures v0.3.31 [INFO] [stderr] Compiling x509-parser v0.17.0 [INFO] [stderr] Compiling rustls-connector v0.20.2 [INFO] [stderr] Compiling idna_adapter v1.2.1 [INFO] [stderr] Compiling idna v1.0.3 [INFO] [stderr] Compiling p12-keystore v0.1.5 [INFO] [stderr] Compiling tokio-stream v0.1.17 [INFO] [stderr] Compiling tokio-rustls v0.25.0 [INFO] [stderr] Compiling url v2.5.4 [INFO] [stderr] Compiling tokio-executor-trait v2.1.3 [INFO] [stderr] Compiling rumqttc v0.24.0 [INFO] [stderr] Compiling tcp-stream v0.28.0 [INFO] [stderr] Compiling tokio-reactor-trait v1.1.0 [INFO] [stderr] Compiling bincode v1.3.3 [INFO] [stderr] Compiling amq-protocol-types v7.2.3 [INFO] [stderr] Compiling amq-protocol-uri v7.2.3 [INFO] [stderr] Compiling amq-protocol-tcp v7.2.3 [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)]` (part of `#[warn(unused)]`) 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)]` (part of `#[warn(unused)]`) 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)]` (part of `#[warn(unused)]`) 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 1m 51s [INFO] running `Command { std: "docker" "inspect" "f9363270f775cf54d03f4d78d2b0d212a000ffba083e4e9125da3fdbfca1d87d", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "f9363270f775cf54d03f4d78d2b0d212a000ffba083e4e9125da3fdbfca1d87d", kill_on_drop: false }` [INFO] [stdout] f9363270f775cf54d03f4d78d2b0d212a000ffba083e4e9125da3fdbfca1d87d [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-6-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-6-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=forbid" "-e" "RUSTDOCFLAGS=--cap-lints=forbid" "-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:7ad1b28ee6f5f7f699f6cf7015098d6ccdd96d6f2d78dd06228f5b4c9faf309c" "/opt/rustwide/cargo-home/bin/cargo" "+cdb45c87e2cd43495379f7e867e3cc15dcee9f93" "test" "--frozen" "--no-run" "--message-format=json", kill_on_drop: false }` [INFO] [stdout] ccf1b78244e802ef16fdb03a250513b48165556735d0fdcf80302b0710fa22bc [INFO] running `Command { std: "docker" "start" "-a" "ccf1b78244e802ef16fdb03a250513b48165556735d0fdcf80302b0710fa22bc", kill_on_drop: false }` [INFO] [stderr] Compiling ring v0.17.14 [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 v0.1.41 [INFO] [stderr] Compiling futures-util v0.3.31 [INFO] [stderr] Compiling async-executor v1.13.2 [INFO] [stderr] Compiling polling v2.8.0 [INFO] [stderr] Compiling clap_builder v4.5.41 [INFO] [stderr] Compiling ciborium-ll v0.2.2 [INFO] [stderr] Compiling regex-automata v0.4.9 [INFO] [stderr] Compiling async-stream-impl v0.3.6 [INFO] [stderr] Compiling wait-timeout v0.2.1 [INFO] [stderr] Compiling bit-vec v0.8.0 [INFO] [stderr] Compiling plotters v0.3.7 [INFO] [stderr] Compiling event-listener-strategy v0.5.4 [INFO] [stderr] Compiling async-io v1.13.0 [INFO] [stderr] Compiling async-channel v2.5.0 [INFO] [stderr] Compiling async-lock v3.4.0 [INFO] [stderr] Compiling pinky-swear v6.2.0 [INFO] [stderr] Compiling bit-set v0.8.0 [INFO] [stderr] Compiling rand_xorshift v0.4.0 [INFO] [stderr] Compiling blocking v1.6.2 [INFO] [stderr] Compiling async-stream v0.3.6 [INFO] [stderr] Compiling is-terminal v0.4.16 [INFO] [stderr] Compiling unarray v0.1.4 [INFO] [stderr] Compiling tracing-subscriber v0.3.19 [INFO] [stderr] Compiling async-reactor-trait v1.1.0 [INFO] [stderr] Compiling clap v4.5.41 [INFO] [stderr] Compiling regex v1.11.1 [INFO] [stderr] Compiling rustls-webpki v0.103.4 [INFO] [stderr] Compiling rustls-webpki v0.102.8 [INFO] [stderr] Compiling rustls v0.22.4 [INFO] [stderr] Compiling rustls v0.23.29 [INFO] [stderr] Compiling serde_json v1.0.141 [INFO] [stderr] Compiling ciborium v0.2.2 [INFO] [stderr] Compiling bincode v1.3.3 [INFO] [stderr] Compiling chrono v0.4.41 [INFO] [stderr] Compiling polling v3.9.0 [INFO] [stderr] Compiling tempfile v3.20.0 [INFO] [stderr] Compiling futures-executor v0.3.31 [INFO] [stderr] Compiling futures v0.3.31 [INFO] [stderr] Compiling async-io v2.5.0 [INFO] [stderr] Compiling rusty-fork v0.3.0 [INFO] [stderr] Compiling proptest v1.7.0 [INFO] [stderr] Compiling amq-protocol-types v7.2.3 [INFO] [stderr] Compiling tinytemplate v1.2.1 [INFO] [stderr] Compiling async-global-executor v3.1.0 [INFO] [stderr] Compiling tokio-stream v0.1.17 [INFO] [stderr] Compiling tokio-executor-trait v2.1.3 [INFO] [stderr] Compiling rdkafka v0.36.2 [INFO] [stderr] Compiling async-global-executor-trait v2.2.0 [INFO] [stderr] Compiling amq-protocol-uri v7.2.3 [INFO] [stderr] Compiling tokio-reactor-trait v1.1.0 [INFO] [stderr] Compiling tokio-test v0.4.4 [INFO] [stderr] Compiling criterion v0.5.1 [INFO] [stderr] Compiling tokio-rustls v0.25.0 [INFO] [stderr] Compiling rumqttc v0.24.0 [INFO] [stderr] Compiling rustls-connector v0.20.2 [INFO] [stderr] Compiling tcp-stream v0.28.0 [INFO] [stderr] Compiling amq-protocol-tcp v7.2.3 [INFO] [stderr] Compiling amq-protocol v7.2.3 [INFO] [stderr] Compiling lapin v2.5.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)]` (part of `#[warn(unused)]`) 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)]` (part of `#[warn(unused)]`) 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)]` (part of `#[warn(unused)]`) 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 + timestamp, [INFO] [stdout] 30 + offset, [INFO] [stdout] 31 + delivery_count, [INFO] [stdout] 32 + partition, [INFO] [stdout] 33 ~ ); [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 + timestamp, [INFO] [stdout] 57 + offset, [INFO] [stdout] 58 + 1, [INFO] [stdout] 59 + partition, [INFO] [stdout] 60 ~ ); [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 + timestamp, [INFO] [stdout] 68 + offset, [INFO] [stdout] 69 + 2, [INFO] [stdout] 70 + partition, [INFO] [stdout] 71 ~ ); [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 + timestamp, [INFO] [stdout] 79 + offset, [INFO] [stdout] 80 + 5, [INFO] [stdout] 81 + partition, [INFO] [stdout] 82 ~ ); [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 + timestamp, [INFO] [stdout] 99 + offset, [INFO] [stdout] 100 + delivery_count, [INFO] [stdout] 101 + partition, [INFO] [stdout] 102 ~ ); [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 + timestamp, [INFO] [stdout] 108 + offset, [INFO] [stdout] 109 + delivery_count, [INFO] [stdout] 110 + partition, [INFO] [stdout] 111 ~ ); [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 + timestamp, [INFO] [stdout] 136 + /* u32 */, [INFO] [stdout] 137 + 1, [INFO] [stdout] 138 + partition, [INFO] [stdout] 139 ~ ); [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 + timestamp, [INFO] [stdout] 160 + offset, [INFO] [stdout] 161 + delivery_count, [INFO] [stdout] 162 + partition, [INFO] [stdout] 163 ~ ); [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 + timestamp, [INFO] [stdout] 191 + offset, [INFO] [stdout] 192 + delivery_count, [INFO] [stdout] 193 + partition, [INFO] [stdout] 194 ~ ); [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] | ^^^^^^^^^^ unsatisfied trait bound [INFO] [stdout] | [INFO] [stdout] help: the trait `std::fmt::Debug` is not implemented for `kafka::ack::KafkaAckSubscriber` [INFO] [stdout] --> src/kafka/ack.rs:91:1 [INFO] [stdout] | [INFO] [stdout] 91 | pub struct 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/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/core/src/result.rs:1314: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 + SystemTime::now(), [INFO] [stdout] 363 + delivery_count, [INFO] [stdout] 364 + partition, [INFO] [stdout] 365 + /* i64 */, [INFO] [stdout] 366 ~ ); [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 + timestamp, [INFO] [stdout] 424 + offset, [INFO] [stdout] 425 + delivery_count, [INFO] [stdout] 426 + partition, [INFO] [stdout] 427 ~ ); [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 + timestamp, [INFO] [stdout] 467 + /* u32 */, [INFO] [stdout] 468 + 1, [INFO] [stdout] 469 + partition, [INFO] [stdout] 470 ~ ); [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 + SystemTime::now(), [INFO] [stdout] 498 + offset, [INFO] [stdout] 499 + count, [INFO] [stdout] 500 + partition, [INFO] [stdout] 501 ~ ); [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 + SystemTime::now(), [INFO] [stdout] 524 + /* u32 */, [INFO] [stdout] 525 + 1, [INFO] [stdout] 526 + /* i64 */, [INFO] [stdout] 527 ~ ); [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 + SystemTime::now(), [INFO] [stdout] 544 + 12345, [INFO] [stdout] 545 + 3, [INFO] [stdout] 546 + 2, [INFO] [stdout] 547 ~ ); [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 + SystemTime::now(), [INFO] [stdout] 578 + /* u32 */, [INFO] [stdout] 579 + 1, [INFO] [stdout] 580 + /* i64 */, [INFO] [stdout] 581 ~ )) [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] 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)]` (part of `#[warn(unused)]`) 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] 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 + timestamp, [INFO] [stdout] 63 + delivery_count, [INFO] [stdout] 64 + qos, [INFO] [stdout] 65 + packet_id, [INFO] [stdout] 66 ~ ); [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 + timestamp, [INFO] [stdout] 98 + 2, [INFO] [stdout] 99 + qos, [INFO] [stdout] 100 + packet_id, [INFO] [stdout] 101 ~ ); [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 + timestamp, [INFO] [stdout] 109 + 5, [INFO] [stdout] 110 + qos, [INFO] [stdout] 111 + packet_id, [INFO] [stdout] 112 ~ ); [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 + timestamp, [INFO] [stdout] 129 + delivery_count, [INFO] [stdout] 130 + qos, [INFO] [stdout] 131 + packet_id, [INFO] [stdout] 132 ~ ); [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 + timestamp, [INFO] [stdout] 138 + delivery_count, [INFO] [stdout] 139 + qos, [INFO] [stdout] 140 + packet_id, [INFO] [stdout] 141 ~ ); [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 + timestamp, [INFO] [stdout] 227 + 0, [INFO] [stdout] 228 + QoS::AtMostOnce, [INFO] [stdout] 229 + None, [INFO] [stdout] 230 ~ ); [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 + timestamp, [INFO] [stdout] 243 + 1, [INFO] [stdout] 244 + QoS::AtLeastOnce, [INFO] [stdout] 245 + Some(1), [INFO] [stdout] 246 ~ ); [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] | ^^^^^^^^^^ unsatisfied trait bound [INFO] [stdout] | [INFO] [stdout] help: the trait `std::fmt::Debug` is not implemented for `mqtt::ack::MQTTAckSubscriber` [INFO] [stdout] --> src/mqtt/ack.rs:99:1 [INFO] [stdout] | [INFO] [stdout] 99 | pub struct 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/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/core/src/result.rs:1314: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 + SystemTime::now(), [INFO] [stdout] 432 + delivery_count, [INFO] [stdout] 433 + qos, [INFO] [stdout] 434 + packet_id, [INFO] [stdout] 435 ~ ); [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 + timestamp, [INFO] [stdout] 463 + delivery_count, [INFO] [stdout] 464 + qos, [INFO] [stdout] 465 + packet_id, [INFO] [stdout] 466 ~ ); [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 + timestamp, [INFO] [stdout] 518 + delivery_count, [INFO] [stdout] 519 + QoS::AtLeastOnce, [INFO] [stdout] 520 + Some(packet_id), [INFO] [stdout] 521 ~ ); [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 + SystemTime::now(), [INFO] [stdout] 548 + count, [INFO] [stdout] 549 + qos, [INFO] [stdout] 550 + packet_id, [INFO] [stdout] 551 ~ ); [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 + SystemTime::now(), [INFO] [stdout] 610 + 1, [INFO] [stdout] 611 + qos, [INFO] [stdout] 612 + packet_id, [INFO] [stdout] 613 ~ ); [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 + timestamp, [INFO] [stdout] 29 + delivery_count, [INFO] [stdout] 30 + delivery_tag, [INFO] [stdout] 31 ~ ); [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 + timestamp, [INFO] [stdout] 53 + 1, [INFO] [stdout] 54 + delivery_tag, [INFO] [stdout] 55 ~ ); [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 + timestamp, [INFO] [stdout] 63 + 2, [INFO] [stdout] 64 + delivery_tag, [INFO] [stdout] 65 ~ ); [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 + timestamp, [INFO] [stdout] 73 + 5, [INFO] [stdout] 74 + delivery_tag, [INFO] [stdout] 75 ~ ); [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 + timestamp, [INFO] [stdout] 91 + delivery_count, [INFO] [stdout] 92 + delivery_tag, [INFO] [stdout] 93 ~ ); [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 + timestamp, [INFO] [stdout] 99 + delivery_count, [INFO] [stdout] 100 + delivery_tag, [INFO] [stdout] 101 ~ ); [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 + timestamp, [INFO] [stdout] 119 + delivery_count, [INFO] [stdout] 120 + delivery_tag, [INFO] [stdout] 121 ~ ); [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 + timestamp, [INFO] [stdout] 147 + delivery_count, [INFO] [stdout] 148 + delivery_tag, [INFO] [stdout] 149 ~ ); [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] | ^^^^^^^^^^ unsatisfied trait bound [INFO] [stdout] | [INFO] [stdout] help: the trait `std::fmt::Debug` is not implemented for `rabbitmq::ack::RabbitMQAckSubscriber` [INFO] [stdout] --> src/rabbitmq/ack.rs:81:1 [INFO] [stdout] | [INFO] [stdout] 81 | pub struct 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/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/core/src/result.rs:1314: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 + timestamp, [INFO] [stdout] 356 + delivery_count, [INFO] [stdout] 357 + delivery_tag, [INFO] [stdout] 358 ~ ); [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 + SystemTime::now(), [INFO] [stdout] 391 + 1, [INFO] [stdout] 392 + i as u64, [INFO] [stdout] 393 ~ ); [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 + SystemTime::now(), [INFO] [stdout] 438 + 1, [INFO] [stdout] 439 + i as u64, [INFO] [stdout] 440 ~ )) [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)]` (part of `#[warn(unused)]`) 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)]` (part of `#[warn(unused)]`) 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] 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] [stdout] warning: unused import: `sleep` [INFO] [stdout] --> tests/comprehensive_integration_tests.rs:15:28 [INFO] [stdout] | [INFO] [stdout] 15 | use tokio::time::{timeout, sleep}; [INFO] [stdout] | ^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> tests/comprehensive_integration_tests.rs:246:17 [INFO] [stdout] | [INFO] [stdout] 246 | let mut subscriber = InMemoryAckSubscriberFixed::new(broker.clone()); [INFO] [stdout] | ----^^^^^^^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_mut)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] running `Command { std: "docker" "inspect" "ccf1b78244e802ef16fdb03a250513b48165556735d0fdcf80302b0710fa22bc", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "ccf1b78244e802ef16fdb03a250513b48165556735d0fdcf80302b0710fa22bc", kill_on_drop: false }` [INFO] [stdout] ccf1b78244e802ef16fdb03a250513b48165556735d0fdcf80302b0710fa22bc