[INFO] fetching crate stomp-rs 0.0.2...
[INFO] testing stomp-rs-0.0.2 against beta-2021-08-01 for beta-1.55-1
[INFO] extracting crate stomp-rs 0.0.2 into /workspace/builds/worker-3/source
[INFO] validating manifest of crates.io crate stomp-rs 0.0.2 on toolchain beta-2021-08-01
[INFO] running `Command { std: "/workspace/cargo-home/bin/cargo" "+beta-2021-08-01" "metadata" "--manifest-path" "Cargo.toml" "--no-deps", kill_on_drop: false }`
[INFO] started tweaking crates.io crate stomp-rs 0.0.2
[INFO] finished tweaking crates.io crate stomp-rs 0.0.2
[INFO] tweaked toml for crates.io crate stomp-rs 0.0.2 written to /workspace/builds/worker-3/source/Cargo.toml
[INFO] running `Command { std: "/workspace/cargo-home/bin/cargo" "+beta-2021-08-01" "generate-lockfile" "--manifest-path" "Cargo.toml" "-Zno-index-update", kill_on_drop: false }`
[INFO] running `Command { std: "/workspace/cargo-home/bin/cargo" "+beta-2021-08-01" "fetch" "--manifest-path" "Cargo.toml", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-3/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-3/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:34b6a614d2c27851fe6cbf88fbd1137609cefab8b10d0615aaeb6fd47975d74e" "/opt/rustwide/cargo-home/bin/cargo" "+beta-2021-08-01" "metadata" "--no-deps" "--format-version=1", kill_on_drop: false }`
[INFO] [stdout] 64d284f6862cb4534b066b0a7cf23e64de16c2ed6ef07775e3fd2b6e09871b55
[INFO] [stderr] WARNING: Your kernel does not support swap limit capabilities or the cgroup is not mounted. Memory limited without swap.
[INFO] running `Command { std: "docker" "start" "-a" "64d284f6862cb4534b066b0a7cf23e64de16c2ed6ef07775e3fd2b6e09871b55", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "inspect" "64d284f6862cb4534b066b0a7cf23e64de16c2ed6ef07775e3fd2b6e09871b55", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "64d284f6862cb4534b066b0a7cf23e64de16c2ed6ef07775e3fd2b6e09871b55", kill_on_drop: false }`
[INFO] [stdout] 64d284f6862cb4534b066b0a7cf23e64de16c2ed6ef07775e3fd2b6e09871b55
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-3/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-3/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=warn" "-e" "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:34b6a614d2c27851fe6cbf88fbd1137609cefab8b10d0615aaeb6fd47975d74e" "/opt/rustwide/cargo-home/bin/cargo" "+beta-2021-08-01" "build" "--frozen" "--message-format=json", kill_on_drop: false }`
[INFO] [stderr] WARNING: Your kernel does not support swap limit capabilities or the cgroup is not mounted. Memory limited without swap.
[INFO] [stdout] 12e292390ed1bb28f3beae692aa83fbc444a97487664d0563f9a7742bb41cad1
[INFO] running `Command { std: "docker" "start" "-a" "12e292390ed1bb28f3beae692aa83fbc444a97487664d0563f9a7742bb41cad1", kill_on_drop: false }`
[INFO] [stderr]    Compiling uuid v0.8.2
[INFO] [stderr]    Compiling stomp-rs v0.0.2 (/opt/rustwide/workdir)
[INFO] [stdout] warning: unused import: `tokio::sync::mpsc::error::SendError`
[INFO] [stdout]   --> src/client/inner.rs:13:5
[INFO] [stdout]    |
[INFO] [stdout] 13 | use tokio::sync::mpsc::error::SendError;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `#[warn(unused_imports)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `tokio::net::TcpStream`
[INFO] [stdout]  --> src/client.rs:3:5
[INFO] [stdout]   |
[INFO] [stdout] 3 | use tokio::net::TcpStream;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `crate::connection::Connection`
[INFO] [stdout]  --> src/client.rs:4:5
[INFO] [stdout]   |
[INFO] [stdout] 4 | use crate::connection::Connection;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `channel`
[INFO] [stdout]  --> src/client.rs:5:25
[INFO] [stdout]   |
[INFO] [stdout] 5 | use tokio::sync::mpsc::{channel, Sender};
[INFO] [stdout]   |                         ^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `Connect`, `Send`, `Subscribe`, `Unsubscribe`
[INFO] [stdout]  --> src/client.rs:6:30
[INFO] [stdout]   |
[INFO] [stdout] 6 | use crate::protocol::frame::{Connect, Subscribe, Unsubscribe, Send, Begin, Commit, Abort};
[INFO] [stdout]   |                              ^^^^^^^  ^^^^^^^^^  ^^^^^^^^^^^  ^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `ClientCommand`
[INFO] [stdout]  --> src/client.rs:8:59
[INFO] [stdout]   |
[INFO] [stdout] 8 | use crate::protocol::{StompMessage, ServerCommand, Frame, ClientCommand};
[INFO] [stdout]   |                                                           ^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `Duration`, `Instant`
[INFO] [stdout]  --> src/client.rs:9:19
[INFO] [stdout]   |
[INFO] [stdout] 9 | use tokio::time::{Duration, Instant};
[INFO] [stdout]   |                   ^^^^^^^^  ^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `tokio::sync::Mutex`
[INFO] [stdout]   --> src/client.rs:13:5
[INFO] [stdout]    |
[INFO] [stdout] 13 | use tokio::sync::Mutex;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `std::collections::HashMap`
[INFO] [stdout]   --> src/client.rs:14:5
[INFO] [stdout]    |
[INFO] [stdout] 14 | use std::collections::HashMap;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `tokio::sync::mpsc::error::SendError`
[INFO] [stdout]   --> src/client.rs:16:5
[INFO] [stdout]    |
[INFO] [stdout] 16 | use tokio::sync::mpsc::error::SendError;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `tokio::sync::oneshot::Receiver`
[INFO] [stdout]  --> src/connection.rs:7:5
[INFO] [stdout]   |
[INFO] [stdout] 7 | use tokio::sync::oneshot::Receiver;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/client/inner.rs:167:26
[INFO] [stdout]     |
[INFO] [stdout] 167 |             let (sender, mut receiver) = channel(1);
[INFO] [stdout]     |                          ----^^^^^^^^
[INFO] [stdout]     |                          |
[INFO] [stdout]     |                          help: remove this `mut`
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(unused_mut)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/protocol/mod.rs:267:25
[INFO] [stdout]     |
[INFO] [stdout] 267 |                     let mut frame_command = std::mem::take(&mut self.current_command);
[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/protocol/mod.rs:268:25
[INFO] [stdout]     |
[INFO] [stdout] 268 |                     let mut frame_headers = std::mem::take(&mut self.current_headers);
[INFO] [stdout]     |                         ----^^^^^^^^^^^^^
[INFO] [stdout]     |                         |
[INFO] [stdout]     |                         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variant is never constructed: `LF`
[INFO] [stdout]    --> src/protocol/mod.rs:139:5
[INFO] [stdout]     |
[INFO] [stdout] 139 |     LF,
[INFO] [stdout]     |     ^^
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(dead_code)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variant is never constructed: `CR`
[INFO] [stdout]    --> src/protocol/mod.rs:140:5
[INFO] [stdout]     |
[INFO] [stdout] 140 |     CR,
[INFO] [stdout]     |     ^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variant is never constructed: `Octet`
[INFO] [stdout]    --> src/protocol/mod.rs:141:5
[INFO] [stdout]     |
[INFO] [stdout] 141 |     Octet,
[INFO] [stdout]     |     ^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variant is never constructed: `Null`
[INFO] [stdout]    --> src/protocol/mod.rs:142:5
[INFO] [stdout]     |
[INFO] [stdout] 142 |     Null,
[INFO] [stdout]     |     ^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: field is never read: `sender`
[INFO] [stdout]   --> src/client/inner.rs:17:5
[INFO] [stdout]    |
[INFO] [stdout] 17 |     sender: ServerStompSender,
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated function is never used: `new`
[INFO] [stdout]   --> src/client.rs:28:8
[INFO] [stdout]    |
[INFO] [stdout] 28 |     fn new(transaction_id: String, inner_client: Arc<InnerClient>) -> Self {
[INFO] [stdout]    |        ^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: field is never read: `server_sender`
[INFO] [stdout]   --> src/connection.rs:11:5
[INFO] [stdout]    |
[INFO] [stdout] 11 |     server_sender: Sender<StompMessage<ServerCommand>>,
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused implementer of `std::future::Future` that must be used
[INFO] [stdout]   --> src/client/inner.rs:46:21
[INFO] [stdout]    |
[INFO] [stdout] 46 | /                     connection
[INFO] [stdout] 47 | |                         .clone()
[INFO] [stdout] 48 | |                         .close();
[INFO] [stdout]    | |_________________________________^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `#[warn(unused_must_use)]` on by default
[INFO] [stdout]    = note: futures do nothing unless you `.await` or poll them
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused `Result` that must be used
[INFO] [stdout]   --> src/client/inner.rs:59:37
[INFO] [stdout]    |
[INFO] [stdout] 59 | ...                   pending_sender.send(StompMessage::Frame(frame.clone())).await;
[INFO] [stdout]    |                       ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: this `Result` may be an `Err` variant, which should be handled
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused `Result` that must be used
[INFO] [stdout]   --> src/client/inner.rs:67:37
[INFO] [stdout]    |
[INFO] [stdout] 67 | ...                   sub_sender.send(StompMessage::Frame(frame.clone())).await;
[INFO] [stdout]    |                       ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: this `Result` may be an `Err` variant, which should be handled
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused implementer of `std::future::Future` that must be used
[INFO] [stdout]   --> src/connection.rs:93:9
[INFO] [stdout]    |
[INFO] [stdout] 93 |         self.close_sender.send(());
[INFO] [stdout]    |         ^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: futures do nothing unless you `.await` or poll them
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: 25 warnings emitted
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stderr]     Finished dev [unoptimized + debuginfo] target(s) in 1.28s
[INFO] running `Command { std: "docker" "inspect" "12e292390ed1bb28f3beae692aa83fbc444a97487664d0563f9a7742bb41cad1", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "12e292390ed1bb28f3beae692aa83fbc444a97487664d0563f9a7742bb41cad1", kill_on_drop: false }`
[INFO] [stdout] 12e292390ed1bb28f3beae692aa83fbc444a97487664d0563f9a7742bb41cad1
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-3/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-3/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=warn" "-e" "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:34b6a614d2c27851fe6cbf88fbd1137609cefab8b10d0615aaeb6fd47975d74e" "/opt/rustwide/cargo-home/bin/cargo" "+beta-2021-08-01" "test" "--frozen" "--no-run" "--message-format=json", kill_on_drop: false }`
[INFO] [stdout] d441f11215603bb423aeae62697b1e4dd8ce77be52f44a27b26c416365b15bc3
[INFO] [stderr] WARNING: Your kernel does not support swap limit capabilities or the cgroup is not mounted. Memory limited without swap.
[INFO] running `Command { std: "docker" "start" "-a" "d441f11215603bb423aeae62697b1e4dd8ce77be52f44a27b26c416365b15bc3", kill_on_drop: false }`
[INFO] [stdout] warning: unused import: `tokio::sync::mpsc::error::SendError`
[INFO] [stdout]   --> src/client/inner.rs:13:5
[INFO] [stdout]    |
[INFO] [stdout] 13 | use tokio::sync::mpsc::error::SendError;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `#[warn(unused_imports)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `tokio::net::TcpStream`
[INFO] [stdout]  --> src/client.rs:3:5
[INFO] [stdout]   |
[INFO] [stdout] 3 | use tokio::net::TcpStream;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `crate::connection::Connection`
[INFO] [stdout]  --> src/client.rs:4:5
[INFO] [stdout]   |
[INFO] [stdout] 4 | use crate::connection::Connection;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `channel`
[INFO] [stdout]  --> src/client.rs:5:25
[INFO] [stdout]   |
[INFO] [stdout] 5 | use tokio::sync::mpsc::{channel, Sender};
[INFO] [stdout]   |                         ^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `Connect`, `Send`, `Subscribe`, `Unsubscribe`
[INFO] [stdout]  --> src/client.rs:6:30
[INFO] [stdout]   |
[INFO] [stdout] 6 | use crate::protocol::frame::{Connect, Subscribe, Unsubscribe, Send, Begin, Commit, Abort};
[INFO] [stdout]   |                              ^^^^^^^  ^^^^^^^^^  ^^^^^^^^^^^  ^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `ClientCommand`
[INFO] [stdout]  --> src/client.rs:8:59
[INFO] [stdout]   |
[INFO] [stdout] 8 | use crate::protocol::{StompMessage, ServerCommand, Frame, ClientCommand};
[INFO] [stdout]   |                                                           ^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `Duration`, `Instant`
[INFO] [stdout]  --> src/client.rs:9:19
[INFO] [stdout]   |
[INFO] [stdout] 9 | use tokio::time::{Duration, Instant};
[INFO] [stdout]   |                   ^^^^^^^^  ^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `tokio::sync::Mutex`
[INFO] [stdout]   --> src/client.rs:13:5
[INFO] [stdout]    |
[INFO] [stdout] 13 | use tokio::sync::Mutex;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `std::collections::HashMap`
[INFO] [stdout]   --> src/client.rs:14:5
[INFO] [stdout]    |
[INFO] [stdout] 14 | use std::collections::HashMap;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `tokio::sync::mpsc::error::SendError`
[INFO] [stdout]   --> src/client.rs:16:5
[INFO] [stdout]    |
[INFO] [stdout] 16 | use tokio::sync::mpsc::error::SendError;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `tokio::sync::oneshot::Receiver`
[INFO] [stdout]  --> src/connection.rs:7:5
[INFO] [stdout]   |
[INFO] [stdout] 7 | use tokio::sync::oneshot::Receiver;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/client/inner.rs:167:26
[INFO] [stdout]     |
[INFO] [stdout] 167 |             let (sender, mut receiver) = channel(1);
[INFO] [stdout]     |                          ----^^^^^^^^
[INFO] [stdout]     |                          |
[INFO] [stdout]     |                          help: remove this `mut`
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(unused_mut)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/protocol/mod.rs:267:25
[INFO] [stdout]     |
[INFO] [stdout] 267 |                     let mut frame_command = std::mem::take(&mut self.current_command);
[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/protocol/mod.rs:268:25
[INFO] [stdout]     |
[INFO] [stdout] 268 |                     let mut frame_headers = std::mem::take(&mut self.current_headers);
[INFO] [stdout]     |                         ----^^^^^^^^^^^^^
[INFO] [stdout]     |                         |
[INFO] [stdout]     |                         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variant is never constructed: `LF`
[INFO] [stdout]    --> src/protocol/mod.rs:139:5
[INFO] [stdout]     |
[INFO] [stdout] 139 |     LF,
[INFO] [stdout]     |     ^^
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(dead_code)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variant is never constructed: `CR`
[INFO] [stdout]    --> src/protocol/mod.rs:140:5
[INFO] [stdout]     |
[INFO] [stdout] 140 |     CR,
[INFO] [stdout]     |     ^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variant is never constructed: `Octet`
[INFO] [stdout]    --> src/protocol/mod.rs:141:5
[INFO] [stdout]     |
[INFO] [stdout] 141 |     Octet,
[INFO] [stdout]     |     ^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variant is never constructed: `Null`
[INFO] [stdout]    --> src/protocol/mod.rs:142:5
[INFO] [stdout]     |
[INFO] [stdout] 142 |     Null,
[INFO] [stdout]     |     ^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: field is never read: `sender`
[INFO] [stdout]   --> src/client/inner.rs:17:5
[INFO] [stdout]    |
[INFO] [stdout] 17 |     sender: ServerStompSender,
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated function is never used: `new`
[INFO] [stdout]   --> src/client.rs:28:8
[INFO] [stdout]    |
[INFO] [stdout] 28 |     fn new(transaction_id: String, inner_client: Arc<InnerClient>) -> Self {
[INFO] [stdout]    |        ^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: field is never read: `server_sender`
[INFO] [stdout]   --> src/connection.rs:11:5
[INFO] [stdout]    |
[INFO] [stdout] 11 |     server_sender: Sender<StompMessage<ServerCommand>>,
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused implementer of `std::future::Future` that must be used
[INFO] [stdout]   --> src/client/inner.rs:46:21
[INFO] [stdout]    |
[INFO] [stdout] 46 | /                     connection
[INFO] [stdout] 47 | |                         .clone()
[INFO] [stdout] 48 | |                         .close();
[INFO] [stdout]    | |_________________________________^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `#[warn(unused_must_use)]` on by default
[INFO] [stdout]    = note: futures do nothing unless you `.await` or poll them
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused `Result` that must be used
[INFO] [stdout]   --> src/client/inner.rs:59:37
[INFO] [stdout]    |
[INFO] [stdout] 59 | ...                   pending_sender.send(StompMessage::Frame(frame.clone())).await;
[INFO] [stdout]    |                       ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: this `Result` may be an `Err` variant, which should be handled
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused `Result` that must be used
[INFO] [stdout]   --> src/client/inner.rs:67:37
[INFO] [stdout]    |
[INFO] [stdout] 67 | ...                   sub_sender.send(StompMessage::Frame(frame.clone())).await;
[INFO] [stdout]    |                       ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: this `Result` may be an `Err` variant, which should be handled
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused implementer of `std::future::Future` that must be used
[INFO] [stdout]   --> src/connection.rs:93:9
[INFO] [stdout]    |
[INFO] [stdout] 93 |         self.close_sender.send(());
[INFO] [stdout]    |         ^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: futures do nothing unless you `.await` or poll them
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stderr]    Compiling stomp-rs v0.0.2 (/opt/rustwide/workdir)
[INFO] [stdout] warning: 25 warnings emitted
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `tokio::sync::mpsc::error::SendError`
[INFO] [stdout]   --> src/client/inner.rs:13:5
[INFO] [stdout]    |
[INFO] [stdout] 13 | use tokio::sync::mpsc::error::SendError;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `#[warn(unused_imports)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `tokio::net::TcpStream`
[INFO] [stdout]  --> src/client.rs:3:5
[INFO] [stdout]   |
[INFO] [stdout] 3 | use tokio::net::TcpStream;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `crate::connection::Connection`
[INFO] [stdout]  --> src/client.rs:4:5
[INFO] [stdout]   |
[INFO] [stdout] 4 | use crate::connection::Connection;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `channel`
[INFO] [stdout]  --> src/client.rs:5:25
[INFO] [stdout]   |
[INFO] [stdout] 5 | use tokio::sync::mpsc::{channel, Sender};
[INFO] [stdout]   |                         ^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `Connect`, `Send`, `Subscribe`, `Unsubscribe`
[INFO] [stdout]  --> src/client.rs:6:30
[INFO] [stdout]   |
[INFO] [stdout] 6 | use crate::protocol::frame::{Connect, Subscribe, Unsubscribe, Send, Begin, Commit, Abort};
[INFO] [stdout]   |                              ^^^^^^^  ^^^^^^^^^  ^^^^^^^^^^^  ^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `ClientCommand`
[INFO] [stdout]  --> src/client.rs:8:59
[INFO] [stdout]   |
[INFO] [stdout] 8 | use crate::protocol::{StompMessage, ServerCommand, Frame, ClientCommand};
[INFO] [stdout]   |                                                           ^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `Duration`, `Instant`
[INFO] [stdout]  --> src/client.rs:9:19
[INFO] [stdout]   |
[INFO] [stdout] 9 | use tokio::time::{Duration, Instant};
[INFO] [stdout]   |                   ^^^^^^^^  ^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `tokio::sync::Mutex`
[INFO] [stdout]   --> src/client.rs:13:5
[INFO] [stdout]    |
[INFO] [stdout] 13 | use tokio::sync::Mutex;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `std::collections::HashMap`
[INFO] [stdout]   --> src/client.rs:14:5
[INFO] [stdout]    |
[INFO] [stdout] 14 | use std::collections::HashMap;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `tokio::sync::mpsc::error::SendError`
[INFO] [stdout]   --> src/client.rs:16:5
[INFO] [stdout]    |
[INFO] [stdout] 16 | use tokio::sync::mpsc::error::SendError;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `tokio::sync::oneshot::Receiver`
[INFO] [stdout]  --> src/connection.rs:7:5
[INFO] [stdout]   |
[INFO] [stdout] 7 | use tokio::sync::oneshot::Receiver;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/client/inner.rs:167:26
[INFO] [stdout]     |
[INFO] [stdout] 167 |             let (sender, mut receiver) = channel(1);
[INFO] [stdout]     |                          ----^^^^^^^^
[INFO] [stdout]     |                          |
[INFO] [stdout]     |                          help: remove this `mut`
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(unused_mut)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/protocol/mod.rs:267:25
[INFO] [stdout]     |
[INFO] [stdout] 267 |                     let mut frame_command = std::mem::take(&mut self.current_command);
[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/protocol/mod.rs:268:25
[INFO] [stdout]     |
[INFO] [stdout] 268 |                     let mut frame_headers = std::mem::take(&mut self.current_headers);
[INFO] [stdout]     |                         ----^^^^^^^^^^^^^
[INFO] [stdout]     |                         |
[INFO] [stdout]     |                         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variant is never constructed: `LF`
[INFO] [stdout]    --> src/protocol/mod.rs:139:5
[INFO] [stdout]     |
[INFO] [stdout] 139 |     LF,
[INFO] [stdout]     |     ^^
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(dead_code)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variant is never constructed: `CR`
[INFO] [stdout]    --> src/protocol/mod.rs:140:5
[INFO] [stdout]     |
[INFO] [stdout] 140 |     CR,
[INFO] [stdout]     |     ^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variant is never constructed: `Octet`
[INFO] [stdout]    --> src/protocol/mod.rs:141:5
[INFO] [stdout]     |
[INFO] [stdout] 141 |     Octet,
[INFO] [stdout]     |     ^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variant is never constructed: `Null`
[INFO] [stdout]    --> src/protocol/mod.rs:142:5
[INFO] [stdout]     |
[INFO] [stdout] 142 |     Null,
[INFO] [stdout]     |     ^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: field is never read: `sender`
[INFO] [stdout]   --> src/client/inner.rs:17:5
[INFO] [stdout]    |
[INFO] [stdout] 17 |     sender: ServerStompSender,
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated function is never used: `new`
[INFO] [stdout]   --> src/client.rs:28:8
[INFO] [stdout]    |
[INFO] [stdout] 28 |     fn new(transaction_id: String, inner_client: Arc<InnerClient>) -> Self {
[INFO] [stdout]    |        ^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: field is never read: `server_sender`
[INFO] [stdout]   --> src/connection.rs:11:5
[INFO] [stdout]    |
[INFO] [stdout] 11 |     server_sender: Sender<StompMessage<ServerCommand>>,
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused implementer of `std::future::Future` that must be used
[INFO] [stdout]   --> src/client/inner.rs:46:21
[INFO] [stdout]    |
[INFO] [stdout] 46 | /                     connection
[INFO] [stdout] 47 | |                         .clone()
[INFO] [stdout] 48 | |                         .close();
[INFO] [stdout]    | |_________________________________^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `#[warn(unused_must_use)]` on by default
[INFO] [stdout]    = note: futures do nothing unless you `.await` or poll them
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused `Result` that must be used
[INFO] [stdout]   --> src/client/inner.rs:59:37
[INFO] [stdout]    |
[INFO] [stdout] 59 | ...                   pending_sender.send(StompMessage::Frame(frame.clone())).await;
[INFO] [stdout]    |                       ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: this `Result` may be an `Err` variant, which should be handled
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused `Result` that must be used
[INFO] [stdout]   --> src/client/inner.rs:67:37
[INFO] [stdout]    |
[INFO] [stdout] 67 | ...                   sub_sender.send(StompMessage::Frame(frame.clone())).await;
[INFO] [stdout]    |                       ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: this `Result` may be an `Err` variant, which should be handled
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused implementer of `std::future::Future` that must be used
[INFO] [stdout]   --> src/connection.rs:93:9
[INFO] [stdout]    |
[INFO] [stdout] 93 |         self.close_sender.send(());
[INFO] [stdout]    |         ^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: futures do nothing unless you `.await` or poll them
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: 25 warnings emitted
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stderr]     Finished test [unoptimized + debuginfo] target(s) in 1.86s
[INFO] running `Command { std: "docker" "inspect" "d441f11215603bb423aeae62697b1e4dd8ce77be52f44a27b26c416365b15bc3", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "d441f11215603bb423aeae62697b1e4dd8ce77be52f44a27b26c416365b15bc3", kill_on_drop: false }`
[INFO] [stdout] d441f11215603bb423aeae62697b1e4dd8ce77be52f44a27b26c416365b15bc3
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-3/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-3/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=warn" "-e" "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:34b6a614d2c27851fe6cbf88fbd1137609cefab8b10d0615aaeb6fd47975d74e" "/opt/rustwide/cargo-home/bin/cargo" "+beta-2021-08-01" "test" "--frozen", kill_on_drop: false }`
[INFO] [stdout] 280d596854ceb9f1ff3b57f96f8ac4d1104cd99573bc285e2c4c0544a19f3a23
[INFO] [stderr] WARNING: Your kernel does not support swap limit capabilities or the cgroup is not mounted. Memory limited without swap.
[INFO] running `Command { std: "docker" "start" "-a" "280d596854ceb9f1ff3b57f96f8ac4d1104cd99573bc285e2c4c0544a19f3a23", kill_on_drop: false }`
[INFO] [stderr]     Blocking waiting for file lock on package cache
[INFO] [stderr] warning: unused import: `tokio::sync::mpsc::error::SendError`
[INFO] [stderr]   --> src/client/inner.rs:13:5
[INFO] [stderr]    |
[INFO] [stderr] 13 | use tokio::sync::mpsc::error::SendError;
[INFO] [stderr]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr]    |
[INFO] [stderr]    = note: `#[warn(unused_imports)]` on by default
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `tokio::net::TcpStream`
[INFO] [stderr]  --> src/client.rs:3:5
[INFO] [stderr]   |
[INFO] [stderr] 3 | use tokio::net::TcpStream;
[INFO] [stderr]   |     ^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `crate::connection::Connection`
[INFO] [stderr]  --> src/client.rs:4:5
[INFO] [stderr]   |
[INFO] [stderr] 4 | use crate::connection::Connection;
[INFO] [stderr]   |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `channel`
[INFO] [stderr]  --> src/client.rs:5:25
[INFO] [stderr]   |
[INFO] [stderr] 5 | use tokio::sync::mpsc::{channel, Sender};
[INFO] [stderr]   |                         ^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused imports: `Connect`, `Send`, `Subscribe`, `Unsubscribe`
[INFO] [stderr]  --> src/client.rs:6:30
[INFO] [stderr]   |
[INFO] [stderr] 6 | use crate::protocol::frame::{Connect, Subscribe, Unsubscribe, Send, Begin, Commit, Abort};
[INFO] [stderr]   |                              ^^^^^^^  ^^^^^^^^^  ^^^^^^^^^^^  ^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `ClientCommand`
[INFO] [stderr]  --> src/client.rs:8:59
[INFO] [stderr]   |
[INFO] [stderr] 8 | use crate::protocol::{StompMessage, ServerCommand, Frame, ClientCommand};
[INFO] [stderr]   |                                                           ^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused imports: `Duration`, `Instant`
[INFO] [stderr]  --> src/client.rs:9:19
[INFO] [stderr]   |
[INFO] [stderr] 9 | use tokio::time::{Duration, Instant};
[INFO] [stderr]   |                   ^^^^^^^^  ^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `tokio::sync::Mutex`
[INFO] [stderr]   --> src/client.rs:13:5
[INFO] [stderr]    |
[INFO] [stderr] 13 | use tokio::sync::Mutex;
[INFO] [stderr]    |     ^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `std::collections::HashMap`
[INFO] [stderr]   --> src/client.rs:14:5
[INFO] [stderr]    |
[INFO] [stderr] 14 | use std::collections::HashMap;
[INFO] [stderr]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `tokio::sync::mpsc::error::SendError`
[INFO] [stderr]   --> src/client.rs:16:5
[INFO] [stderr]    |
[INFO] [stderr] 16 | use tokio::sync::mpsc::error::SendError;
[INFO] [stderr]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `tokio::sync::oneshot::Receiver`
[INFO] [stderr]  --> src/connection.rs:7:5
[INFO] [stderr]   |
[INFO] [stderr] 7 | use tokio::sync::oneshot::Receiver;
[INFO] [stderr]   |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: variable does not need to be mutable
[INFO] [stderr]    --> src/client/inner.rs:167:26
[INFO] [stderr]     |
[INFO] [stderr] 167 |             let (sender, mut receiver) = channel(1);
[INFO] [stderr]     |                          ----^^^^^^^^
[INFO] [stderr]     |                          |
[INFO] [stderr]     |                          help: remove this `mut`
[INFO] [stderr]     |
[INFO] [stderr]     = note: `#[warn(unused_mut)]` on by default
[INFO] [stderr] 
[INFO] [stderr] warning: variable does not need to be mutable
[INFO] [stderr]    --> src/protocol/mod.rs:267:25
[INFO] [stderr]     |
[INFO] [stderr] 267 |                     let mut frame_command = std::mem::take(&mut self.current_command);
[INFO] [stderr]     |                         ----^^^^^^^^^^^^^
[INFO] [stderr]     |                         |
[INFO] [stderr]     |                         help: remove this `mut`
[INFO] [stderr] 
[INFO] [stderr] warning: variable does not need to be mutable
[INFO] [stderr]    --> src/protocol/mod.rs:268:25
[INFO] [stderr]     |
[INFO] [stderr] 268 |                     let mut frame_headers = std::mem::take(&mut self.current_headers);
[INFO] [stderr]     |                         ----^^^^^^^^^^^^^
[INFO] [stderr]     |                         |
[INFO] [stderr]     |                         help: remove this `mut`
[INFO] [stderr] 
[INFO] [stderr] warning: variant is never constructed: `LF`
[INFO] [stderr]    --> src/protocol/mod.rs:139:5
[INFO] [stderr]     |
[INFO] [stderr] 139 |     LF,
[INFO] [stderr]     |     ^^
[INFO] [stderr]     |
[INFO] [stderr]     = note: `#[warn(dead_code)]` on by default
[INFO] [stderr] 
[INFO] [stderr] warning: variant is never constructed: `CR`
[INFO] [stderr]    --> src/protocol/mod.rs:140:5
[INFO] [stderr]     |
[INFO] [stderr] 140 |     CR,
[INFO] [stderr]     |     ^^
[INFO] [stderr] 
[INFO] [stderr] warning: variant is never constructed: `Octet`
[INFO] [stderr]    --> src/protocol/mod.rs:141:5
[INFO] [stderr]     |
[INFO] [stderr] 141 |     Octet,
[INFO] [stderr]     |     ^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: variant is never constructed: `Null`
[INFO] [stderr]    --> src/protocol/mod.rs:142:5
[INFO] [stderr]     |
[INFO] [stderr] 142 |     Null,
[INFO] [stderr]     |     ^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: field is never read: `sender`
[INFO] [stderr]   --> src/client/inner.rs:17:5
[INFO] [stderr]    |
[INFO] [stderr] 17 |     sender: ServerStompSender,
[INFO] [stderr]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: associated function is never used: `new`
[INFO] [stderr]   --> src/client.rs:28:8
[INFO] [stderr]    |
[INFO] [stderr] 28 |     fn new(transaction_id: String, inner_client: Arc<InnerClient>) -> Self {
[INFO] [stderr]    |        ^^^
[INFO] [stderr] 
[INFO] [stderr] warning: field is never read: `server_sender`
[INFO] [stderr]   --> src/connection.rs:11:5
[INFO] [stderr]    |
[INFO] [stderr] 11 |     server_sender: Sender<StompMessage<ServerCommand>>,
[INFO] [stderr]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused implementer of `std::future::Future` that must be used
[INFO] [stderr]   --> src/client/inner.rs:46:21
[INFO] [stderr]    |
[INFO] [stderr] 46 | /                     connection
[INFO] [stderr] 47 | |                         .clone()
[INFO] [stderr] 48 | |                         .close();
[INFO] [stderr]    | |_________________________________^
[INFO] [stderr]    |
[INFO] [stderr]    = note: `#[warn(unused_must_use)]` on by default
[INFO] [stderr]    = note: futures do nothing unless you `.await` or poll them
[INFO] [stderr] 
[INFO] [stderr] warning: unused `Result` that must be used
[INFO] [stderr]   --> src/client/inner.rs:59:37
[INFO] [stderr]    |
[INFO] [stderr] 59 | ...                   pending_sender.send(StompMessage::Frame(frame.clone())).await;
[INFO] [stderr]    |                       ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr]    |
[INFO] [stderr]    = note: this `Result` may be an `Err` variant, which should be handled
[INFO] [stderr] 
[INFO] [stderr] warning: unused `Result` that must be used
[INFO] [stderr]   --> src/client/inner.rs:67:37
[INFO] [stderr]    |
[INFO] [stderr] 67 | ...                   sub_sender.send(StompMessage::Frame(frame.clone())).await;
[INFO] [stderr]    |                       ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr]    |
[INFO] [stderr]    = note: this `Result` may be an `Err` variant, which should be handled
[INFO] [stderr] 
[INFO] [stderr] warning: unused implementer of `std::future::Future` that must be used
[INFO] [stderr]   --> src/connection.rs:93:9
[INFO] [stderr]    |
[INFO] [stderr] 93 |         self.close_sender.send(());
[INFO] [stderr]    |         ^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr]    |
[INFO] [stderr]    = note: futures do nothing unless you `.await` or poll them
[INFO] [stderr] 
[INFO] [stderr] warning: `stomp-rs` (lib) generated 25 warnings
[INFO] [stderr] warning: `stomp-rs` (lib test) generated 25 warnings (25 duplicates)
[INFO] [stderr]     Finished test [unoptimized + debuginfo] target(s) in 0.04s
[INFO] [stderr]      Running unittests (/opt/rustwide/target/debug/deps/stomp_rs-343352d56ed0ca0f)
[INFO] [stdout] 
[INFO] [stdout] running 7 tests
[INFO] [stdout] test protocol::frame::tests::test_ack ... ok
[INFO] [stdout] test protocol::frame::tests::test_connect ... ok
[INFO] [stdout] test protocol::frame::tests::test_nack ... ok
[INFO] [stdout] test protocol::frame::tests::test_send ... ok
[INFO] [stdout] test protocol::test::parse_test ... ok
[INFO] [stdout] test protocol::test::parse_test_cr ... ok
[INFO] [stdout] test protocol::frame::tests::test_subscribe ... ok
[INFO] [stdout] 
[INFO] [stdout] test result: ok. 7 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s
[INFO] [stdout] 
[INFO] [stderr]    Doc-tests stomp-rs
[INFO] [stdout] 
[INFO] [stdout] running 2 tests
[INFO] [stdout] test src/lib.rs - (line 5) - compile ... FAILED
[INFO] [stdout] test src/lib.rs - (line 17) - compile ... FAILED
[INFO] [stdout] 
[INFO] [stdout] failures:
[INFO] [stdout] 
[INFO] [stdout] ---- src/lib.rs - (line 5) stdout ----
[INFO] [stdout] error[E0432]: unresolved import `stomp_rs::Client`
[INFO] [stdout]  --> src/lib.rs:6:5
[INFO] [stdout]   |
[INFO] [stdout] 4 | use stomp_rs::Client;
[INFO] [stdout]   |     ^^^^^^^^^^------
[INFO] [stdout]   |     |         |
[INFO] [stdout]   |     |         help: a similar name exists in the module (notice the capitalization): `client`
[INFO] [stdout]   |     no `Client` in the root
[INFO] [stdout] 
[INFO] [stdout] error[E0425]: cannot find value `sender` in this scope
[INFO] [stdout]  --> src/lib.rs:11:5
[INFO] [stdout]   |
[INFO] [stdout] 9 |     sender,
[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.rs:9:14
[INFO] [stdout]    |
[INFO] [stdout] 3  |   fn main() { #[allow(non_snake_case)] fn _doctest_main_src_lib_rs_5_0() {
[INFO] [stdout]    |                                           ---------------------------- this is not `async`
[INFO] [stdout] ...
[INFO] [stdout] 7  |   let client = Client::new(
[INFO] [stdout]    |  ______________^
[INFO] [stdout] 8  | |     TcpStream::connect("127.0.0.1:61613").await?,
[INFO] [stdout] 9  | |     sender,
[INFO] [stdout] 10 | | ).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.rs:10:5
[INFO] [stdout]   |
[INFO] [stdout] 3 | fn main() { #[allow(non_snake_case)] fn _doctest_main_src_lib_rs_5_0() {
[INFO] [stdout]   |                                         ---------------------------- this is not `async`
[INFO] [stdout] ...
[INFO] [stdout] 8 |     TcpStream::connect("127.0.0.1:61613").await?,
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ only allowed inside `async` functions and blocks
[INFO] [stdout] 
[INFO] [stdout] error[E0277]: the `?` operator can only be used in a function that returns `Result` or `Option` (or another type that implements `FromResidual`)
[INFO] [stdout]    --> src/lib.rs:10:48
[INFO] [stdout]     |
[INFO] [stdout] 3   |   fn main() { #[allow(non_snake_case)] fn _doctest_main_src_lib_rs_5_0() {
[INFO] [stdout]     |  ______________________________________-
[INFO] [stdout] 4   | | use stomp_rs::Client;
[INFO] [stdout] 5   | | use tokio::net::TcpStream;
[INFO] [stdout] 6   | |
[INFO] [stdout] 7   | | let client = Client::new(
[INFO] [stdout] 8   | |     TcpStream::connect("127.0.0.1:61613").await?,
[INFO] [stdout]     | |                                                ^ cannot use the `?` operator in a function that returns `()`
[INFO] [stdout] 9   | |     sender,
[INFO] [stdout] 10  | | ).await?;
[INFO] [stdout] 11  | | } _doctest_main_src_lib_rs_5_0() }
[INFO] [stdout]     | |_- this function should return `Result` or `Option` to accept `?`
[INFO] [stdout]     |
[INFO] [stdout]     = help: the trait `FromResidual<Result<Infallible, std::io::Error>>` is not implemented for `()`
[INFO] [stdout] note: required by `from_residual`
[INFO] [stdout] 
[INFO] [stdout] error[E0277]: the `?` operator can only be used in a function that returns `Result` or `Option` (or another type that implements `FromResidual`)
[INFO] [stdout]    --> src/lib.rs:12:8
[INFO] [stdout]     |
[INFO] [stdout] 3   |   fn main() { #[allow(non_snake_case)] fn _doctest_main_src_lib_rs_5_0() {
[INFO] [stdout]     |  ______________________________________-
[INFO] [stdout] 4   | | use stomp_rs::Client;
[INFO] [stdout] 5   | | use tokio::net::TcpStream;
[INFO] [stdout] 6   | |
[INFO] [stdout] ...   |
[INFO] [stdout] 10  | | ).await?;
[INFO] [stdout]     | |        ^ cannot use the `?` operator in a function that returns `()`
[INFO] [stdout] 11  | | } _doctest_main_src_lib_rs_5_0() }
[INFO] [stdout]     | |_- this function should return `Result` or `Option` to accept `?`
[INFO] [stdout]     |
[INFO] [stdout]     = help: the trait `FromResidual<_>` is not implemented for `()`
[INFO] [stdout] note: required by `from_residual`
[INFO] [stdout] 
[INFO] [stdout] error: aborting due to 6 previous errors
[INFO] [stdout] 
[INFO] [stdout] Some errors have detailed explanations: E0277, E0425, E0432, E0728.
[INFO] [stdout] For more information about an error, try `rustc --explain E0277`.
[INFO] [stdout] Couldn't compile the test.
[INFO] [stdout] ---- src/lib.rs - (line 17) stdout ----
[INFO] [stdout] error[E0425]: cannot find value `client` in this scope
[INFO] [stdout]  --> src/lib.rs:20:1
[INFO] [stdout]   |
[INFO] [stdout] 6 | client.send(
[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.rs:20:1
[INFO] [stdout]    |
[INFO] [stdout] 3  |   fn main() { #[allow(non_snake_case)] fn _doctest_main_src_lib_rs_17_0() {
[INFO] [stdout]    |                                           ----------------------------- this is not `async`
[INFO] [stdout] ...
[INFO] [stdout] 6  | / client.send(
[INFO] [stdout] 7  | |     "/topic/test".to_string(),
[INFO] [stdout] 8  | |     "test-message".to_string(),
[INFO] [stdout] 9  | |     None,
[INFO] [stdout] 10 | | ).await?
[INFO] [stdout]    | |_______^ only allowed inside `async` functions and blocks
[INFO] [stdout] 
[INFO] [stdout] error[E0277]: the `?` operator can only be used in a function that returns `Result` or `Option` (or another type that implements `FromResidual`)
[INFO] [stdout]    --> src/lib.rs:24:8
[INFO] [stdout]     |
[INFO] [stdout] 3   |   fn main() { #[allow(non_snake_case)] fn _doctest_main_src_lib_rs_17_0() {
[INFO] [stdout]     |  ______________________________________-
[INFO] [stdout] 4   | | use stomp_rs::protocol::frame::Send;
[INFO] [stdout] 5   | |
[INFO] [stdout] 6   | | client.send(
[INFO] [stdout] ...   |
[INFO] [stdout] 10  | | ).await?
[INFO] [stdout]     | |        ^ cannot use the `?` operator in a function that returns `()`
[INFO] [stdout] 11  | | } _doctest_main_src_lib_rs_17_0() }
[INFO] [stdout]     | |_- this function should return `Result` or `Option` to accept `?`
[INFO] [stdout]     |
[INFO] [stdout]     = help: the trait `FromResidual<_>` is not implemented for `()`
[INFO] [stdout] note: required by `from_residual`
[INFO] [stdout] 
[INFO] [stdout] error: aborting due to 3 previous errors
[INFO] [stdout] 
[INFO] [stdout] Some errors have detailed explanations: E0277, E0425, E0728.
[INFO] [stdout] For more information about an error, try `rustc --explain E0277`.
[INFO] [stdout] Couldn't compile the test.
[INFO] [stdout] 
[INFO] [stdout] failures:
[INFO] [stdout]     src/lib.rs - (line 17)
[INFO] [stdout]     src/lib.rs - (line 5)
[INFO] [stdout] 
[INFO] [stdout] test result: FAILED. 0 passed; 2 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.26s
[INFO] [stdout] 
[INFO] [stderr] error: test failed, to rerun pass '--doc'
[INFO] running `Command { std: "docker" "inspect" "280d596854ceb9f1ff3b57f96f8ac4d1104cd99573bc285e2c4c0544a19f3a23", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "280d596854ceb9f1ff3b57f96f8ac4d1104cd99573bc285e2c4c0544a19f3a23", kill_on_drop: false }`
[INFO] [stdout] 280d596854ceb9f1ff3b57f96f8ac4d1104cd99573bc285e2c4c0544a19f3a23
