[INFO] fetching crate ahrimq 0.0.5... [INFO] testing ahrimq-0.0.5 against master#cdb45c87e2cd43495379f7e867e3cc15dcee9f93 for pr-145838-1 [INFO] extracting crate ahrimq 0.0.5 into /workspace/builds/worker-0-tc1/source [INFO] started tweaking crates.io crate ahrimq 0.0.5 [INFO] removed 0 missing examples [INFO] finished tweaking crates.io crate ahrimq 0.0.5 [INFO] tweaked toml for crates.io crate ahrimq 0.0.5 written to /workspace/builds/worker-0-tc1/source/Cargo.toml [INFO] validating manifest of crates.io crate ahrimq 0.0.5 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 ahrimq 0.0.5 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] Downloading crates ... [INFO] [stderr] Downloaded bincode_derive v2.0.1 [INFO] [stderr] Downloaded unty v0.0.4 [INFO] [stderr] Downloaded virtue v0.0.18 [INFO] [stderr] Downloaded bincode v2.0.1 [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-0-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-0-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] 8a7696abae5291a3f810921c54215a5ee4691d536cf48beb62de159aed325d73 [INFO] running `Command { std: "docker" "start" "-a" "8a7696abae5291a3f810921c54215a5ee4691d536cf48beb62de159aed325d73", kill_on_drop: false }` [INFO] running `Command { std: "docker" "inspect" "8a7696abae5291a3f810921c54215a5ee4691d536cf48beb62de159aed325d73", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "8a7696abae5291a3f810921c54215a5ee4691d536cf48beb62de159aed325d73", kill_on_drop: false }` [INFO] [stdout] 8a7696abae5291a3f810921c54215a5ee4691d536cf48beb62de159aed325d73 [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-0-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-0-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] fa322f246870d1198cbd3925315fdb99aa813029c9d6f49bf749f61d59cf18dd [INFO] running `Command { std: "docker" "start" "-a" "fa322f246870d1198cbd3925315fdb99aa813029c9d6f49bf749f61d59cf18dd", kill_on_drop: false }` [INFO] [stderr] Compiling proc-macro2 v1.0.94 [INFO] [stderr] Compiling libc v0.2.171 [INFO] [stderr] Compiling serde v1.0.219 [INFO] [stderr] Compiling smallvec v1.14.0 [INFO] [stderr] Compiling virtue v0.0.18 [INFO] [stderr] Compiling unty v0.0.4 [INFO] [stderr] Compiling memchr v2.7.4 [INFO] [stderr] Compiling bincode_derive v2.0.1 [INFO] [stderr] Compiling quote v1.0.40 [INFO] [stderr] Compiling syn v2.0.100 [INFO] [stderr] Compiling parking_lot_core v0.9.10 [INFO] [stderr] Compiling signal-hook-registry v1.4.2 [INFO] [stderr] Compiling socket2 v0.5.9 [INFO] [stderr] Compiling mio v1.0.3 [INFO] [stderr] Compiling parking_lot v0.12.3 [INFO] [stderr] Compiling serde_derive v1.0.219 [INFO] [stderr] Compiling tokio-macros v2.5.0 [INFO] [stderr] Compiling tokio v1.44.1 [INFO] [stderr] Compiling toml v0.5.11 [INFO] [stderr] Compiling bincode v2.0.1 [INFO] [stderr] Compiling serde_json v1.0.140 [INFO] [stderr] Compiling ahrimq v0.0.5 (/opt/rustwide/workdir) [INFO] [stderr] Finished `dev` profile [unoptimized + debuginfo] target(s) in 25.29s [INFO] running `Command { std: "docker" "inspect" "fa322f246870d1198cbd3925315fdb99aa813029c9d6f49bf749f61d59cf18dd", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "fa322f246870d1198cbd3925315fdb99aa813029c9d6f49bf749f61d59cf18dd", kill_on_drop: false }` [INFO] [stdout] fa322f246870d1198cbd3925315fdb99aa813029c9d6f49bf749f61d59cf18dd [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-0-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-0-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] 713cc6b6ec6617c98635ed85bf060ef5527f6a64f60e7722557615c36d038dd3 [INFO] running `Command { std: "docker" "start" "-a" "713cc6b6ec6617c98635ed85bf060ef5527f6a64f60e7722557615c36d038dd3", kill_on_drop: false }` [INFO] [stderr] Compiling ahrimq v0.0.5 (/opt/rustwide/workdir) [INFO] [stderr] Finished `test` profile [unoptimized + debuginfo] target(s) in 4.38s [INFO] running `Command { std: "docker" "inspect" "713cc6b6ec6617c98635ed85bf060ef5527f6a64f60e7722557615c36d038dd3", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "713cc6b6ec6617c98635ed85bf060ef5527f6a64f60e7722557615c36d038dd3", kill_on_drop: false }` [INFO] [stdout] 713cc6b6ec6617c98635ed85bf060ef5527f6a64f60e7722557615c36d038dd3 [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-0-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-0-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", kill_on_drop: false }` [INFO] [stdout] 3e190113c4ba04997205234115344d00b819f983cce77470f0075b44f01a7c8d [INFO] running `Command { std: "docker" "start" "-a" "3e190113c4ba04997205234115344d00b819f983cce77470f0075b44f01a7c8d", kill_on_drop: false }` [INFO] [stderr] Finished `test` profile [unoptimized + debuginfo] target(s) in 0.10s [INFO] [stdout] [INFO] [stderr] Running unittests src/lib/mod.rs (/opt/rustwide/target/debug/deps/amq-52638799c70e06a3) [INFO] [stdout] running 1 test [INFO] [stderr] Running unittests src/cli/main.rs (/opt/rustwide/target/debug/deps/amqc-082b1655fa2b4bfb) [INFO] [stdout] test message::tests::test_serialize_deserialize ... ok [INFO] [stderr] Running unittests src/server/main.rs (/opt/rustwide/target/debug/deps/amqs-40115b68d728761d) [INFO] [stdout] [INFO] [stderr] Doc-tests amq [INFO] [stdout] test result: ok. 1 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] running 0 tests [INFO] [stdout] [INFO] [stdout] test result: ok. 0 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] running 0 tests [INFO] [stdout] [INFO] [stdout] test result: ok. 0 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] running 16 tests [INFO] [stdout] test src/lib/client/client_sync.rs - client::client_sync::Client::consume (line 158) ... FAILED [INFO] [stdout] test src/lib/client/client_sync.rs - client::client_sync::Client::subscribe (line 109) ... FAILED [INFO] [stdout] test src/lib/client/client_sync.rs - client::client_sync::Client::publish (line 144) ... FAILED [INFO] [stdout] test src/lib/client/client_async.rs - client::client_async::Client::ack_multi (line 223) ... FAILED [INFO] [stdout] test src/lib/client/client_async.rs - client::client_async::Client (line 36) ... FAILED [INFO] [stdout] test src/lib/client/client_sync.rs - client::client_sync::Client::unsubscribe (line 130) ... FAILED [INFO] [stdout] test src/lib/client/client_sync.rs - client::client_sync::Client::ack (line 193) ... FAILED [INFO] [stdout] test src/lib/client/client_async.rs - client::client_async::Client::unsubscribe (line 148) ... FAILED [INFO] [stdout] test src/lib/client/client_async.rs - client::client_async::Client::unconsume (line 198) ... FAILED [INFO] [stdout] test src/lib/client/client_async.rs - client::client_async::Client::ack (line 212) ... FAILED [INFO] [stdout] test src/lib/client/client_sync.rs - client::client_sync::Client::ack_multi (line 204) ... FAILED [INFO] [stdout] test src/lib/client/client_async.rs - client::client_async::Client::subscribe (line 125) ... FAILED [INFO] [stdout] test src/lib/client/client_async.rs - client::client_async::Client::publish (line 162) ... FAILED [INFO] [stdout] test src/lib/client/client_sync.rs - client::client_sync::Client::unconsume (line 179) ... FAILED [INFO] [stdout] test src/lib/client/client_async.rs - client::client_async::Client::consume (line 176) ... FAILED [INFO] [stdout] test src/lib/client/client_sync.rs - client::client_sync::Client (line 30) ... FAILED [INFO] [stdout] [INFO] [stdout] failures: [INFO] [stdout] [INFO] [stdout] ---- src/lib/client/client_sync.rs - client::client_sync::Client::consume (line 158) stdout ---- [INFO] [stdout] error[E0425]: cannot find value `client` in this scope [INFO] [stdout] --> src/lib/client/client_sync.rs:159:1 [INFO] [stdout] | [INFO] [stdout] 3 | client.consume("topic", |msg| { [INFO] [stdout] | ^^^^^^ not found in this scope [INFO] [stdout] [INFO] [stdout] error: aborting due to 1 previous error [INFO] [stdout] [INFO] [stdout] For more information about this error, try `rustc --explain E0425`. [INFO] [stdout] Couldn't compile the test. [INFO] [stdout] ---- src/lib/client/client_sync.rs - client::client_sync::Client::subscribe (line 109) stdout ---- [INFO] [stdout] error[E0425]: cannot find value `client` in this scope [INFO] [stdout] --> src/lib/client/client_sync.rs:110:1 [INFO] [stdout] | [INFO] [stdout] 3 | client.subscribe("topic", |msg| { [INFO] [stdout] | ^^^^^^ not found in this scope [INFO] [stdout] [INFO] [stdout] error: aborting due to 1 previous error [INFO] [stdout] [INFO] [stdout] For more information about this error, try `rustc --explain E0425`. [INFO] [stdout] Couldn't compile the test. [INFO] [stdout] ---- src/lib/client/client_sync.rs - client::client_sync::Client::publish (line 144) stdout ---- [INFO] [stdout] error[E0425]: cannot find value `client` in this scope [INFO] [stdout] --> src/lib/client/client_sync.rs:145:1 [INFO] [stdout] | [INFO] [stdout] 3 | client.publish("topic", "Hello, world!".as_bytes().to_vec()).unwrap(); [INFO] [stdout] | ^^^^^^ not found in this scope [INFO] [stdout] [INFO] [stdout] error: aborting due to 1 previous error [INFO] [stdout] [INFO] [stdout] For more information about this error, try `rustc --explain E0425`. [INFO] [stdout] Couldn't compile the test. [INFO] [stdout] ---- src/lib/client/client_async.rs - client::client_async::Client::ack_multi (line 223) stdout ---- [INFO] [stdout] error[E0425]: cannot find value `client` in this scope [INFO] [stdout] --> src/lib/client/client_async.rs:224:1 [INFO] [stdout] | [INFO] [stdout] 3 | client.ack_multi(vec![message_id1, message_id2]).await.unwrap(); [INFO] [stdout] | ^^^^^^ not found in this scope [INFO] [stdout] [INFO] [stdout] error[E0425]: cannot find value `message_id1` in this scope [INFO] [stdout] --> src/lib/client/client_async.rs:224:23 [INFO] [stdout] | [INFO] [stdout] 3 | client.ack_multi(vec![message_id1, message_id2]).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^ not found in this scope [INFO] [stdout] [INFO] [stdout] error[E0425]: cannot find value `message_id2` in this scope [INFO] [stdout] --> src/lib/client/client_async.rs:224:36 [INFO] [stdout] | [INFO] [stdout] 3 | client.ack_multi(vec![message_id1, message_id2]).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^ not found in this scope [INFO] [stdout] [INFO] [stdout] error[E0728]: `await` is only allowed inside `async` functions and blocks [INFO] [stdout] --> src/lib/client/client_async.rs:224:50 [INFO] [stdout] | [INFO] [stdout] 2 | fn main() { #[allow(non_snake_case)] fn _doctest_main_src_lib_client_client_async_rs_223_0() { [INFO] [stdout] | ------------------------------------------------------- this is not `async` [INFO] [stdout] 3 | client.ack_multi(vec![message_id1, message_id2]).await.unwrap(); [INFO] [stdout] | ^^^^^ only allowed inside `async` functions and blocks [INFO] [stdout] [INFO] [stdout] error: aborting due to 4 previous errors [INFO] [stdout] [INFO] [stdout] Some errors have detailed explanations: E0425, E0728. [INFO] [stdout] For more information about an error, try `rustc --explain E0425`. [INFO] [stdout] Couldn't compile the test. [INFO] [stdout] ---- src/lib/client/client_async.rs - client::client_async::Client (line 36) stdout ---- [INFO] [stdout] error: cannot find macro `select` in this scope [INFO] [stdout] --> src/lib/client/client_async.rs:57:23 [INFO] [stdout] | [INFO] [stdout] 23 | let should_exit = select! { [INFO] [stdout] | ^^^^^^ [INFO] [stdout] | [INFO] [stdout] help: consider importing this macro [INFO] [stdout] | [INFO] [stdout] 2 + use tokio::select; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `Config` [INFO] [stdout] --> src/lib/client/client_async.rs:38:18 [INFO] [stdout] | [INFO] [stdout] 4 | let config = Config::new().unwrap(); [INFO] [stdout] | ^^^^^^ use of undeclared type `Config` [INFO] [stdout] | [INFO] [stdout] help: consider importing one of these items [INFO] [stdout] | [INFO] [stdout] 2 + use amq::Config; [INFO] [stdout] | [INFO] [stdout] 2 + use bincode::config::Config; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `AsyncClient` [INFO] [stdout] --> src/lib/client/client_async.rs:40:22 [INFO] [stdout] | [INFO] [stdout] 6 | let mut client = AsyncClient::new(config); [INFO] [stdout] | ^^^^^^^^^^^ use of undeclared type `AsyncClient` [INFO] [stdout] | [INFO] [stdout] help: consider importing this struct [INFO] [stdout] | [INFO] [stdout] 2 + use amq::AsyncClient; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] error[E0425]: cannot find function `sleep` in this scope [INFO] [stdout] --> src/lib/client/client_async.rs:46:13 [INFO] [stdout] | [INFO] [stdout] 12 | sleep(Duration::from_secs(1)).await; [INFO] [stdout] | ^^^^^ not found in this scope [INFO] [stdout] | [INFO] [stdout] help: consider importing one of these functions [INFO] [stdout] | [INFO] [stdout] 2 + use std::thread::sleep; [INFO] [stdout] | [INFO] [stdout] 2 + use tokio::time::sleep; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `Duration` [INFO] [stdout] --> src/lib/client/client_async.rs:46:19 [INFO] [stdout] | [INFO] [stdout] 12 | sleep(Duration::from_secs(1)).await; [INFO] [stdout] | ^^^^^^^^ use of undeclared type `Duration` [INFO] [stdout] | [INFO] [stdout] help: consider importing one of these structs [INFO] [stdout] | [INFO] [stdout] 2 + use std::time::Duration; [INFO] [stdout] | [INFO] [stdout] 2 + use tokio::time::Duration; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] error[E0728]: `await` is only allowed inside `async` functions and blocks [INFO] [stdout] --> src/lib/client/client_async.rs:42:37 [INFO] [stdout] | [INFO] [stdout] 2 | fn main() { #[allow(non_snake_case)] fn _doctest_main_src_lib_client_client_async_rs_36_0() { [INFO] [stdout] | ------------------------------------------------------ this is not `async` [INFO] [stdout] ... [INFO] [stdout] 8 | let rx = match client.connect().await { [INFO] [stdout] | ^^^^^ only allowed inside `async` functions and blocks [INFO] [stdout] [INFO] [stdout] error[E0728]: `await` is only allowed inside `async` functions and blocks [INFO] [stdout] --> src/lib/client/client_async.rs:46:43 [INFO] [stdout] | [INFO] [stdout] 2 | fn main() { #[allow(non_snake_case)] fn _doctest_main_src_lib_client_client_async_rs_36_0() { [INFO] [stdout] | ------------------------------------------------------ this is not `async` [INFO] [stdout] ... [INFO] [stdout] 12 | sleep(Duration::from_secs(1)).await; [INFO] [stdout] | ^^^^^ only allowed inside `async` functions and blocks [INFO] [stdout] [INFO] [stdout] error[E0728]: `await` is only allowed inside `async` functions and blocks [INFO] [stdout] --> src/lib/client/client_async.rs:55:10 [INFO] [stdout] | [INFO] [stdout] 2 | fn main() { #[allow(non_snake_case)] fn _doctest_main_src_lib_client_client_async_rs_36_0() { [INFO] [stdout] | ------------------------------------------------------ this is not `async` [INFO] [stdout] ... [INFO] [stdout] 21 | .await?; [INFO] [stdout] | ^^^^^ only allowed inside `async` functions and blocks [INFO] [stdout] [INFO] [stdout] error: aborting due to 8 previous errors [INFO] [stdout] [INFO] [stdout] Some errors have detailed explanations: E0425, E0433, E0728. [INFO] [stdout] For more information about an error, try `rustc --explain E0425`. [INFO] [stdout] Couldn't compile the test. [INFO] [stdout] ---- src/lib/client/client_sync.rs - client::client_sync::Client::unsubscribe (line 130) stdout ---- [INFO] [stdout] error[E0425]: cannot find value `client` in this scope [INFO] [stdout] --> src/lib/client/client_sync.rs:131:1 [INFO] [stdout] | [INFO] [stdout] 3 | client.unsubscribe("topic").unwrap(); [INFO] [stdout] | ^^^^^^ not found in this scope [INFO] [stdout] [INFO] [stdout] error: aborting due to 1 previous error [INFO] [stdout] [INFO] [stdout] For more information about this error, try `rustc --explain E0425`. [INFO] [stdout] Couldn't compile the test. [INFO] [stdout] ---- src/lib/client/client_sync.rs - client::client_sync::Client::ack (line 193) stdout ---- [INFO] [stdout] error[E0425]: cannot find value `client` in this scope [INFO] [stdout] --> src/lib/client/client_sync.rs:194:1 [INFO] [stdout] | [INFO] [stdout] 3 | client.ack(message_id).unwrap(); [INFO] [stdout] | ^^^^^^ not found in this scope [INFO] [stdout] [INFO] [stdout] error[E0425]: cannot find value `message_id` in this scope [INFO] [stdout] --> src/lib/client/client_sync.rs:194:12 [INFO] [stdout] | [INFO] [stdout] 3 | client.ack(message_id).unwrap(); [INFO] [stdout] | ^^^^^^^^^^ not found in this scope [INFO] [stdout] [INFO] [stdout] error: aborting due to 2 previous errors [INFO] [stdout] [INFO] [stdout] For more information about this error, try `rustc --explain E0425`. [INFO] [stdout] Couldn't compile the test. [INFO] [stdout] ---- src/lib/client/client_async.rs - client::client_async::Client::unsubscribe (line 148) stdout ---- [INFO] [stdout] error[E0425]: cannot find value `client` in this scope [INFO] [stdout] --> src/lib/client/client_async.rs:149:1 [INFO] [stdout] | [INFO] [stdout] 3 | client.unsubscribe("topic").await.unwrap(); [INFO] [stdout] | ^^^^^^ not found in this scope [INFO] [stdout] [INFO] [stdout] error[E0728]: `await` is only allowed inside `async` functions and blocks [INFO] [stdout] --> src/lib/client/client_async.rs:149:29 [INFO] [stdout] | [INFO] [stdout] 2 | fn main() { #[allow(non_snake_case)] fn _doctest_main_src_lib_client_client_async_rs_148_0() { [INFO] [stdout] | ------------------------------------------------------- this is not `async` [INFO] [stdout] 3 | client.unsubscribe("topic").await.unwrap(); [INFO] [stdout] | ^^^^^ only allowed inside `async` functions and blocks [INFO] [stdout] [INFO] [stdout] error: aborting due to 2 previous errors [INFO] [stdout] [INFO] [stdout] Some errors have detailed explanations: E0425, E0728. [INFO] [stdout] For more information about an error, try `rustc --explain E0425`. [INFO] [stdout] Couldn't compile the test. [INFO] [stdout] ---- src/lib/client/client_async.rs - client::client_async::Client::unconsume (line 198) stdout ---- [INFO] [stdout] error[E0425]: cannot find value `client` in this scope [INFO] [stdout] --> src/lib/client/client_async.rs:199:1 [INFO] [stdout] | [INFO] [stdout] 3 | client.unconsume("topic").await.unwrap(); [INFO] [stdout] | ^^^^^^ not found in this scope [INFO] [stdout] [INFO] [stdout] error[E0728]: `await` is only allowed inside `async` functions and blocks [INFO] [stdout] --> src/lib/client/client_async.rs:199:27 [INFO] [stdout] | [INFO] [stdout] 2 | fn main() { #[allow(non_snake_case)] fn _doctest_main_src_lib_client_client_async_rs_198_0() { [INFO] [stdout] | ------------------------------------------------------- this is not `async` [INFO] [stdout] 3 | client.unconsume("topic").await.unwrap(); [INFO] [stdout] | ^^^^^ only allowed inside `async` functions and blocks [INFO] [stdout] [INFO] [stdout] error: aborting due to 2 previous errors [INFO] [stdout] [INFO] [stdout] Some errors have detailed explanations: E0425, E0728. [INFO] [stdout] For more information about an error, try `rustc --explain E0425`. [INFO] [stdout] Couldn't compile the test. [INFO] [stdout] ---- src/lib/client/client_async.rs - client::client_async::Client::ack (line 212) stdout ---- [INFO] [stdout] error[E0425]: cannot find value `client` in this scope [INFO] [stdout] --> src/lib/client/client_async.rs:213:1 [INFO] [stdout] | [INFO] [stdout] 3 | client.ack(message_id).await.unwrap(); [INFO] [stdout] | ^^^^^^ not found in this scope [INFO] [stdout] [INFO] [stdout] error[E0425]: cannot find value `message_id` in this scope [INFO] [stdout] --> src/lib/client/client_async.rs:213:12 [INFO] [stdout] | [INFO] [stdout] 3 | client.ack(message_id).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^ not found in this scope [INFO] [stdout] [INFO] [stdout] error[E0728]: `await` is only allowed inside `async` functions and blocks [INFO] [stdout] --> src/lib/client/client_async.rs:213:24 [INFO] [stdout] | [INFO] [stdout] 2 | fn main() { #[allow(non_snake_case)] fn _doctest_main_src_lib_client_client_async_rs_212_0() { [INFO] [stdout] | ------------------------------------------------------- this is not `async` [INFO] [stdout] 3 | client.ack(message_id).await.unwrap(); [INFO] [stdout] | ^^^^^ only allowed inside `async` functions and blocks [INFO] [stdout] [INFO] [stdout] error: aborting due to 3 previous errors [INFO] [stdout] [INFO] [stdout] Some errors have detailed explanations: E0425, E0728. [INFO] [stdout] For more information about an error, try `rustc --explain E0425`. [INFO] [stdout] Couldn't compile the test. [INFO] [stdout] ---- src/lib/client/client_sync.rs - client::client_sync::Client::ack_multi (line 204) stdout ---- [INFO] [stdout] error[E0425]: cannot find value `client` in this scope [INFO] [stdout] --> src/lib/client/client_sync.rs:205:1 [INFO] [stdout] | [INFO] [stdout] 3 | client.ack_multi(vec![message_id1, message_id2]).unwrap(); [INFO] [stdout] | ^^^^^^ not found in this scope [INFO] [stdout] [INFO] [stdout] error[E0425]: cannot find value `message_id1` in this scope [INFO] [stdout] --> src/lib/client/client_sync.rs:205:23 [INFO] [stdout] | [INFO] [stdout] 3 | client.ack_multi(vec![message_id1, message_id2]).unwrap(); [INFO] [stdout] | ^^^^^^^^^^^ not found in this scope [INFO] [stdout] [INFO] [stdout] error[E0425]: cannot find value `message_id2` in this scope [INFO] [stdout] --> src/lib/client/client_sync.rs:205:36 [INFO] [stdout] | [INFO] [stdout] 3 | client.ack_multi(vec![message_id1, message_id2]).unwrap(); [INFO] [stdout] | ^^^^^^^^^^^ not found in this scope [INFO] [stdout] [INFO] [stdout] error: aborting due to 3 previous errors [INFO] [stdout] [INFO] [stdout] For more information about this error, try `rustc --explain E0425`. [INFO] [stdout] Couldn't compile the test. [INFO] [stdout] ---- src/lib/client/client_async.rs - client::client_async::Client::subscribe (line 125) stdout ---- [INFO] [stdout] error[E0425]: cannot find value `client` in this scope [INFO] [stdout] --> src/lib/client/client_async.rs:126:1 [INFO] [stdout] | [INFO] [stdout] 3 | client.subscribe("topic", |msg| async move { [INFO] [stdout] | ^^^^^^ not found in this scope [INFO] [stdout] [INFO] [stdout] error[E0728]: `await` is only allowed inside `async` functions and blocks [INFO] [stdout] --> src/lib/client/client_async.rs:128:4 [INFO] [stdout] | [INFO] [stdout] 2 | fn main() { #[allow(non_snake_case)] fn _doctest_main_src_lib_client_client_async_rs_125_0() { [INFO] [stdout] | ------------------------------------------------------- this is not `async` [INFO] [stdout] ... [INFO] [stdout] 5 | }).await.unwrap(); [INFO] [stdout] | ^^^^^ only allowed inside `async` functions and blocks [INFO] [stdout] [INFO] [stdout] error: aborting due to 2 previous errors [INFO] [stdout] [INFO] [stdout] Some errors have detailed explanations: E0425, E0728. [INFO] [stdout] For more information about an error, try `rustc --explain E0425`. [INFO] [stdout] Couldn't compile the test. [INFO] [stdout] ---- src/lib/client/client_async.rs - client::client_async::Client::publish (line 162) stdout ---- [INFO] [stdout] error[E0425]: cannot find value `client` in this scope [INFO] [stdout] --> src/lib/client/client_async.rs:163:1 [INFO] [stdout] | [INFO] [stdout] 3 | client.publish("topic", "Hello, world!".as_bytes().to_vec()).await.unwrap(); [INFO] [stdout] | ^^^^^^ not found in this scope [INFO] [stdout] [INFO] [stdout] error[E0728]: `await` is only allowed inside `async` functions and blocks [INFO] [stdout] --> src/lib/client/client_async.rs:163:62 [INFO] [stdout] | [INFO] [stdout] 2 | fn main() { #[allow(non_snake_case)] fn _doctest_main_src_lib_client_client_async_rs_162_0() { [INFO] [stdout] | ------------------------------------------------------- this is not `async` [INFO] [stdout] 3 | client.publish("topic", "Hello, world!".as_bytes().to_vec()).await.unwrap(); [INFO] [stdout] | ^^^^^ only allowed inside `async` functions and blocks [INFO] [stdout] [INFO] [stdout] error: aborting due to 2 previous errors [INFO] [stdout] [INFO] [stdout] Some errors have detailed explanations: E0425, E0728. [INFO] [stdout] For more information about an error, try `rustc --explain E0425`. [INFO] [stdout] Couldn't compile the test. [INFO] [stdout] ---- src/lib/client/client_sync.rs - client::client_sync::Client::unconsume (line 179) stdout ---- [INFO] [stdout] error[E0425]: cannot find value `client` in this scope [INFO] [stdout] --> src/lib/client/client_sync.rs:180:1 [INFO] [stdout] | [INFO] [stdout] 3 | client.unconsume("topic").unwrap(); [INFO] [stdout] | ^^^^^^ not found in this scope [INFO] [stdout] [INFO] [stdout] error: aborting due to 1 previous error [INFO] [stdout] [INFO] [stdout] For more information about this error, try `rustc --explain E0425`. [INFO] [stdout] Couldn't compile the test. [INFO] [stdout] ---- src/lib/client/client_async.rs - client::client_async::Client::consume (line 176) stdout ---- [INFO] [stdout] error[E0425]: cannot find value `client` in this scope [INFO] [stdout] --> src/lib/client/client_async.rs:177:1 [INFO] [stdout] | [INFO] [stdout] 3 | client.consume("topic", |msg| async move { [INFO] [stdout] | ^^^^^^ not found in this scope [INFO] [stdout] [INFO] [stdout] error[E0728]: `await` is only allowed inside `async` functions and blocks [INFO] [stdout] --> src/lib/client/client_async.rs:179:4 [INFO] [stdout] | [INFO] [stdout] 2 | fn main() { #[allow(non_snake_case)] fn _doctest_main_src_lib_client_client_async_rs_176_0() { [INFO] [stdout] | ------------------------------------------------------- this is not `async` [INFO] [stdout] ... [INFO] [stdout] 5 | }).await.unwrap(); [INFO] [stdout] | ^^^^^ only allowed inside `async` functions and blocks [INFO] [stdout] [INFO] [stdout] error: aborting due to 2 previous errors [INFO] [stdout] [INFO] [stdout] Some errors have detailed explanations: E0425, E0728. [INFO] [stdout] For more information about an error, try `rustc --explain E0425`. [INFO] [stdout] Couldn't compile the test. [INFO] [stdout] ---- src/lib/client/client_sync.rs - client::client_sync::Client (line 30) stdout ---- [INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `Config` [INFO] [stdout] --> src/lib/client/client_sync.rs:32:18 [INFO] [stdout] | [INFO] [stdout] 4 | let config = Config::new().unwrap(); [INFO] [stdout] | ^^^^^^ use of undeclared type `Config` [INFO] [stdout] | [INFO] [stdout] help: consider importing one of these items [INFO] [stdout] | [INFO] [stdout] 2 + use amq::Config; [INFO] [stdout] | [INFO] [stdout] 2 + use bincode::config::Config; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `SyncClient` [INFO] [stdout] --> src/lib/client/client_sync.rs:34:22 [INFO] [stdout] | [INFO] [stdout] 6 | let mut client = SyncClient::new(config); [INFO] [stdout] | ^^^^^^^^^^ use of undeclared type `SyncClient` [INFO] [stdout] | [INFO] [stdout] help: consider importing this struct [INFO] [stdout] | [INFO] [stdout] 2 + use amq::SyncClient; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] error[E0425]: cannot find function `sleep` in this scope [INFO] [stdout] --> src/lib/client/client_sync.rs:40:13 [INFO] [stdout] | [INFO] [stdout] 12 | sleep(Duration::from_secs(1)); [INFO] [stdout] | ^^^^^ not found in this scope [INFO] [stdout] | [INFO] [stdout] help: consider importing one of these functions [INFO] [stdout] | [INFO] [stdout] 2 + use std::thread::sleep; [INFO] [stdout] | [INFO] [stdout] 2 + use tokio::time::sleep; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `Duration` [INFO] [stdout] --> src/lib/client/client_sync.rs:40:19 [INFO] [stdout] | [INFO] [stdout] 12 | sleep(Duration::from_secs(1)); [INFO] [stdout] | ^^^^^^^^ use of undeclared type `Duration` [INFO] [stdout] | [INFO] [stdout] help: consider importing one of these structs [INFO] [stdout] | [INFO] [stdout] 2 + use std::time::Duration; [INFO] [stdout] | [INFO] [stdout] 2 + use tokio::time::Duration; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `AmqError` [INFO] [stdout] --> src/lib/client/client_sync.rs:53:16 [INFO] [stdout] | [INFO] [stdout] 25 | Ok(AmqError::TcpServerClosed) => { [INFO] [stdout] | ^^^^^^^^ use of undeclared type `AmqError` [INFO] [stdout] | [INFO] [stdout] help: consider importing this enum [INFO] [stdout] | [INFO] [stdout] 2 + use amq::AmqError; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `TryRecvError` [INFO] [stdout] --> src/lib/client/client_sync.rs:62:17 [INFO] [stdout] | [INFO] [stdout] 34 | Err(TryRecvError::Empty) => { [INFO] [stdout] | ^^^^^^^^^^^^ use of undeclared type `TryRecvError` [INFO] [stdout] | [INFO] [stdout] help: consider importing one of these enums [INFO] [stdout] | [INFO] [stdout] 2 + use std::sync::mpsc::TryRecvError; [INFO] [stdout] | [INFO] [stdout] 2 + use tokio::sync::broadcast::error::TryRecvError; [INFO] [stdout] | [INFO] [stdout] 2 + use tokio::sync::mpsc::error::TryRecvError; [INFO] [stdout] | [INFO] [stdout] 2 + use tokio::sync::oneshot::error::TryRecvError; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] error[E0425]: cannot find function `sleep` in this scope [INFO] [stdout] --> src/lib/client/client_sync.rs:63:17 [INFO] [stdout] | [INFO] [stdout] 35 | sleep(Duration::from_secs(1)); [INFO] [stdout] | ^^^^^ not found in this scope [INFO] [stdout] | [INFO] [stdout] help: consider importing one of these functions [INFO] [stdout] | [INFO] [stdout] 2 + use std::thread::sleep; [INFO] [stdout] | [INFO] [stdout] 2 + use tokio::time::sleep; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `Duration` [INFO] [stdout] --> src/lib/client/client_sync.rs:63:23 [INFO] [stdout] | [INFO] [stdout] 35 | sleep(Duration::from_secs(1)); [INFO] [stdout] | ^^^^^^^^ use of undeclared type `Duration` [INFO] [stdout] | [INFO] [stdout] help: consider importing one of these structs [INFO] [stdout] | [INFO] [stdout] 2 + use std::time::Duration; [INFO] [stdout] | [INFO] [stdout] 2 + use tokio::time::Duration; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] error: aborting due to 8 previous errors [INFO] [stdout] [INFO] [stdout] Some errors have detailed explanations: E0425, E0433. [INFO] [stdout] For more information about an error, try `rustc --explain E0425`. [INFO] [stdout] Couldn't compile the test. [INFO] [stdout] [INFO] [stdout] failures: [INFO] [stdout] src/lib/client/client_async.rs - client::client_async::Client (line 36) [INFO] [stdout] src/lib/client/client_async.rs - client::client_async::Client::ack (line 212) [INFO] [stdout] src/lib/client/client_async.rs - client::client_async::Client::ack_multi (line 223) [INFO] [stdout] src/lib/client/client_async.rs - client::client_async::Client::consume (line 176) [INFO] [stdout] src/lib/client/client_async.rs - client::client_async::Client::publish (line 162) [INFO] [stdout] src/lib/client/client_async.rs - client::client_async::Client::subscribe (line 125) [INFO] [stdout] src/lib/client/client_async.rs - client::client_async::Client::unconsume (line 198) [INFO] [stdout] src/lib/client/client_async.rs - client::client_async::Client::unsubscribe (line 148) [INFO] [stdout] src/lib/client/client_sync.rs - client::client_sync::Client (line 30) [INFO] [stdout] src/lib/client/client_sync.rs - client::client_sync::Client::ack (line 193) [INFO] [stdout] src/lib/client/client_sync.rs - client::client_sync::Client::ack_multi (line 204) [INFO] [stdout] src/lib/client/client_sync.rs - client::client_sync::Client::consume (line 158) [INFO] [stdout] src/lib/client/client_sync.rs - client::client_sync::Client::publish (line 144) [INFO] [stdout] src/lib/client/client_sync.rs - client::client_sync::Client::subscribe (line 109) [INFO] [stdout] src/lib/client/client_sync.rs - client::client_sync::Client::unconsume (line 179) [INFO] [stdout] src/lib/client/client_sync.rs - client::client_sync::Client::unsubscribe (line 130) [INFO] [stdout] [INFO] [stdout] test result: FAILED. 0 passed; 16 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.47s [INFO] [stdout] [INFO] [stderr] error: doctest failed, to rerun pass `--doc` [INFO] running `Command { std: "docker" "inspect" "3e190113c4ba04997205234115344d00b819f983cce77470f0075b44f01a7c8d", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "3e190113c4ba04997205234115344d00b819f983cce77470f0075b44f01a7c8d", kill_on_drop: false }` [INFO] [stdout] 3e190113c4ba04997205234115344d00b819f983cce77470f0075b44f01a7c8d