[INFO] cloning repository https://github.com/nrebei2/codecrafters-redis-rust
[INFO] running `Command { std: "git" "-c" "credential.helper=" "-c" "credential.helper=/workspace/cargo-home/bin/git-credential-null" "clone" "--bare" "https://github.com/nrebei2/codecrafters-redis-rust" "/workspace/cache/git-repos/https%3A%2F%2Fgithub.com%2Fnrebei2%2Fcodecrafters-redis-rust", kill_on_drop: false }`
[INFO] [stderr] Cloning into bare repository '/workspace/cache/git-repos/https%3A%2F%2Fgithub.com%2Fnrebei2%2Fcodecrafters-redis-rust'...
[INFO] running `Command { std: "git" "rev-parse" "HEAD", kill_on_drop: false }`
[INFO] [stdout] 53ddda696287c0b135931165fe3e44c3339952ee
[INFO] checking nrebei2/codecrafters-redis-rust against try#6cbf54b1453b438241487f195740266bb9d8c8ba for pr-139587-2
[INFO] running `Command { std: "git" "clone" "/workspace/cache/git-repos/https%3A%2F%2Fgithub.com%2Fnrebei2%2Fcodecrafters-redis-rust" "/workspace/builds/worker-1-tc2/source", kill_on_drop: false }`
[INFO] [stderr] Cloning into '/workspace/builds/worker-1-tc2/source'...
[INFO] [stderr] done.
[INFO] validating manifest of git repo https://github.com/nrebei2/codecrafters-redis-rust on toolchain 6cbf54b1453b438241487f195740266bb9d8c8ba
[INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+6cbf54b1453b438241487f195740266bb9d8c8ba" "metadata" "--manifest-path" "Cargo.toml" "--no-deps", kill_on_drop: false }`
[INFO] started tweaking git repo https://github.com/nrebei2/codecrafters-redis-rust
[INFO] finished tweaking git repo https://github.com/nrebei2/codecrafters-redis-rust
[INFO] tweaked toml for git repo https://github.com/nrebei2/codecrafters-redis-rust written to /workspace/builds/worker-1-tc2/source/Cargo.toml
[INFO] crate git repo https://github.com/nrebei2/codecrafters-redis-rust 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" "+6cbf54b1453b438241487f195740266bb9d8c8ba" "fetch" "--manifest-path" "Cargo.toml", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-1-tc2/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-1-tc2/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:b0b074c097205a61b89e8ad263052f976b2b332c4dc5f02aef1fe52501660d6e" "/opt/rustwide/cargo-home/bin/cargo" "+6cbf54b1453b438241487f195740266bb9d8c8ba" "metadata" "--no-deps" "--format-version=1", kill_on_drop: false }`
[INFO] [stdout] 01bcb2b603d023423449102f52c6ae52fb9b2b29114a44d92cabe4cc5564cce2
[INFO] running `Command { std: "docker" "start" "-a" "01bcb2b603d023423449102f52c6ae52fb9b2b29114a44d92cabe4cc5564cce2", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "inspect" "01bcb2b603d023423449102f52c6ae52fb9b2b29114a44d92cabe4cc5564cce2", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "01bcb2b603d023423449102f52c6ae52fb9b2b29114a44d92cabe4cc5564cce2", kill_on_drop: false }`
[INFO] [stdout] 01bcb2b603d023423449102f52c6ae52fb9b2b29114a44d92cabe4cc5564cce2
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-1-tc2/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-1-tc2/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:b0b074c097205a61b89e8ad263052f976b2b332c4dc5f02aef1fe52501660d6e" "/opt/rustwide/cargo-home/bin/cargo" "+6cbf54b1453b438241487f195740266bb9d8c8ba" "check" "--frozen" "--all" "--all-targets" "--message-format=json", kill_on_drop: false }`
[INFO] [stdout] 54cdc28b1412daa0adc219cf2b77e1b868ed79eb071f5e71a7c11f53c7db6504
[INFO] running `Command { std: "docker" "start" "-a" "54cdc28b1412daa0adc219cf2b77e1b868ed79eb071f5e71a7c11f53c7db6504", kill_on_drop: false }`
[INFO] [stderr]    Compiling libc v0.2.155
[INFO] [stderr]    Compiling anyhow v1.0.86
[INFO] [stderr]    Compiling quote v1.0.36
[INFO] [stderr]    Compiling syn v2.0.87
[INFO] [stderr]     Checking parking_lot_core v0.9.10
[INFO] [stderr]     Checking num_cpus v1.16.0
[INFO] [stderr]     Checking signal-hook-registry v1.4.2
[INFO] [stderr]     Checking socket2 v0.5.7
[INFO] [stderr]     Checking mio v0.8.11
[INFO] [stderr]     Checking parking_lot v0.12.3
[INFO] [stderr]    Compiling tokio-macros v2.3.0
[INFO] [stderr]    Compiling thiserror-impl v1.0.61
[INFO] [stderr]     Checking tokio v1.38.0
[INFO] [stderr]     Checking thiserror v1.0.61
[INFO] [stderr]     Checking redis-starter-rust v0.1.0 (/opt/rustwide/workdir)
[INFO] [stdout] error[E0275]: overflow evaluating the requirement `&mut Deserializer<'_, tokio::io::BufReader<tokio::net::tcp::OwnedReadHalf>>: Send`
[INFO] [stdout]    --> src/main.rs:50:9
[INFO] [stdout]     |
[INFO] [stdout] 50  |         tokio::spawn(replica_handshake(master, state));
[INFO] [stdout]     |         ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = help: consider increasing the recursion limit by adding a `#![recursion_limit = "256"]` attribute to your crate (`redis_starter_rust`)
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> src/resp.rs:220:79
[INFO] [stdout]     |
[INFO] [stdout] 220 |       async fn parse_simple_string(&mut self) -> anyhow::Result<Option<String>> {
[INFO] [stdout]     |  _______________________________________________________________________________^
[INFO] [stdout] 221 | |         let mut buf = vec![];
[INFO] [stdout] 222 | |         self.input.read_until(b'\n', &mut buf).await?;
[INFO] [stdout] ...   |
[INFO] [stdout] 229 | |         Ok(if str == "OK" { None } else { Some(str) })
[INFO] [stdout] 230 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> src/resp.rs:184:60
[INFO] [stdout]     |
[INFO] [stdout] 184 |       pub async fn parse(&mut self) -> anyhow::Result<Value> {
[INFO] [stdout]     |  ____________________________________________________________^
[INFO] [stdout] 185 | |         self.num_bytes += 1;
[INFO] [stdout] 186 | |         Ok(match self.input.read_u8().await? {
[INFO] [stdout] 187 | |             b'+' => match self.parse_simple_string().await? {
[INFO] [stdout] ...   |
[INFO] [stdout] 206 | |         })
[INFO] [stdout] 207 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout]     = note: required for `Unique<impl Future<Output = Result<resp::Value, anyhow::Error>>>` to implement `Send`
[INFO] [stdout] note: required because it appears within the type `Box<impl Future<Output = Result<resp::Value, anyhow::Error>>>`
[INFO] [stdout]    --> /rustc/6cbf54b1453b438241487f195740266bb9d8c8ba/library/alloc/src/boxed.rs:231:12
[INFO] [stdout] note: required because it appears within the type `Pin<Box<impl Future<Output = Result<resp::Value, anyhow::Error>>>>`
[INFO] [stdout]    --> /rustc/6cbf54b1453b438241487f195740266bb9d8c8ba/library/core/src/pin.rs:1094:12
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> src/resp.rs:244:67
[INFO] [stdout]     |
[INFO] [stdout] 244 |       async fn parse_array(&mut self) -> anyhow::Result<Vec<Value>> {
[INFO] [stdout]     |  ___________________________________________________________________^
[INFO] [stdout] 245 | |         let len = self.parse_int().await?;
[INFO] [stdout] 246 | |         let mut arr = Vec::with_capacity(len as usize);
[INFO] [stdout] 247 | |         for _ in 0..len {
[INFO] [stdout] ...   |
[INFO] [stdout] 250 | |         Ok(arr)
[INFO] [stdout] 251 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> src/resp.rs:184:60
[INFO] [stdout]     |
[INFO] [stdout] 184 |       pub async fn parse(&mut self) -> anyhow::Result<Value> {
[INFO] [stdout]     |  ____________________________________________________________^
[INFO] [stdout] 185 | |         self.num_bytes += 1;
[INFO] [stdout] 186 | |         Ok(match self.input.read_u8().await? {
[INFO] [stdout] 187 | |             b'+' => match self.parse_simple_string().await? {
[INFO] [stdout] ...   |
[INFO] [stdout] 206 | |         })
[INFO] [stdout] 207 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout]     = note: required for `Unique<impl Future<Output = Result<resp::Value, anyhow::Error>>>` to implement `Send`
[INFO] [stdout] note: required because it appears within the type `Box<impl Future<Output = Result<resp::Value, anyhow::Error>>>`
[INFO] [stdout]    --> /rustc/6cbf54b1453b438241487f195740266bb9d8c8ba/library/alloc/src/boxed.rs:231:12
[INFO] [stdout] note: required because it appears within the type `Pin<Box<impl Future<Output = Result<resp::Value, anyhow::Error>>>>`
[INFO] [stdout]    --> /rustc/6cbf54b1453b438241487f195740266bb9d8c8ba/library/core/src/pin.rs:1094:12
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> src/resp.rs:244:67
[INFO] [stdout]     |
[INFO] [stdout] 244 |       async fn parse_array(&mut self) -> anyhow::Result<Vec<Value>> {
[INFO] [stdout]     |  ___________________________________________________________________^
[INFO] [stdout] 245 | |         let len = self.parse_int().await?;
[INFO] [stdout] 246 | |         let mut arr = Vec::with_capacity(len as usize);
[INFO] [stdout] 247 | |         for _ in 0..len {
[INFO] [stdout] ...   |
[INFO] [stdout] 250 | |         Ok(arr)
[INFO] [stdout] 251 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> src/resp.rs:184:60
[INFO] [stdout]     |
[INFO] [stdout] 184 |       pub async fn parse(&mut self) -> anyhow::Result<Value> {
[INFO] [stdout]     |  ____________________________________________________________^
[INFO] [stdout] 185 | |         self.num_bytes += 1;
[INFO] [stdout] 186 | |         Ok(match self.input.read_u8().await? {
[INFO] [stdout] 187 | |             b'+' => match self.parse_simple_string().await? {
[INFO] [stdout] ...   |
[INFO] [stdout] 206 | |         })
[INFO] [stdout] 207 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout]     = note: required for `Unique<impl Future<Output = Result<resp::Value, anyhow::Error>>>` to implement `Send`
[INFO] [stdout] note: required because it appears within the type `Box<impl Future<Output = Result<resp::Value, anyhow::Error>>>`
[INFO] [stdout]    --> /rustc/6cbf54b1453b438241487f195740266bb9d8c8ba/library/alloc/src/boxed.rs:231:12
[INFO] [stdout] note: required because it appears within the type `Pin<Box<impl Future<Output = Result<resp::Value, anyhow::Error>>>>`
[INFO] [stdout]    --> /rustc/6cbf54b1453b438241487f195740266bb9d8c8ba/library/core/src/pin.rs:1094:12
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> src/resp.rs:244:67
[INFO] [stdout]     |
[INFO] [stdout] 244 |       async fn parse_array(&mut self) -> anyhow::Result<Vec<Value>> {
[INFO] [stdout]     |  ___________________________________________________________________^
[INFO] [stdout] 245 | |         let len = self.parse_int().await?;
[INFO] [stdout] 246 | |         let mut arr = Vec::with_capacity(len as usize);
[INFO] [stdout] 247 | |         for _ in 0..len {
[INFO] [stdout] ...   |
[INFO] [stdout] 250 | |         Ok(arr)
[INFO] [stdout] 251 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> src/resp.rs:184:60
[INFO] [stdout]     |
[INFO] [stdout] 184 |       pub async fn parse(&mut self) -> anyhow::Result<Value> {
[INFO] [stdout]     |  ____________________________________________________________^
[INFO] [stdout] 185 | |         self.num_bytes += 1;
[INFO] [stdout] 186 | |         Ok(match self.input.read_u8().await? {
[INFO] [stdout] 187 | |             b'+' => match self.parse_simple_string().await? {
[INFO] [stdout] ...   |
[INFO] [stdout] 206 | |         })
[INFO] [stdout] 207 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout]     = note: required for `Unique<impl Future<Output = Result<resp::Value, anyhow::Error>>>` to implement `Send`
[INFO] [stdout] note: required because it appears within the type `Box<impl Future<Output = Result<resp::Value, anyhow::Error>>>`
[INFO] [stdout]    --> /rustc/6cbf54b1453b438241487f195740266bb9d8c8ba/library/alloc/src/boxed.rs:231:12
[INFO] [stdout] note: required because it appears within the type `Pin<Box<impl Future<Output = Result<resp::Value, anyhow::Error>>>>`
[INFO] [stdout]    --> /rustc/6cbf54b1453b438241487f195740266bb9d8c8ba/library/core/src/pin.rs:1094:12
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> src/resp.rs:244:67
[INFO] [stdout]     |
[INFO] [stdout] 244 |       async fn parse_array(&mut self) -> anyhow::Result<Vec<Value>> {
[INFO] [stdout]     |  ___________________________________________________________________^
[INFO] [stdout] 245 | |         let len = self.parse_int().await?;
[INFO] [stdout] 246 | |         let mut arr = Vec::with_capacity(len as usize);
[INFO] [stdout] 247 | |         for _ in 0..len {
[INFO] [stdout] ...   |
[INFO] [stdout] 250 | |         Ok(arr)
[INFO] [stdout] 251 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> src/resp.rs:184:60
[INFO] [stdout]     |
[INFO] [stdout] 184 |       pub async fn parse(&mut self) -> anyhow::Result<Value> {
[INFO] [stdout]     |  ____________________________________________________________^
[INFO] [stdout] 185 | |         self.num_bytes += 1;
[INFO] [stdout] 186 | |         Ok(match self.input.read_u8().await? {
[INFO] [stdout] 187 | |             b'+' => match self.parse_simple_string().await? {
[INFO] [stdout] ...   |
[INFO] [stdout] 206 | |         })
[INFO] [stdout] 207 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout]     = note: required for `Unique<impl Future<Output = Result<resp::Value, anyhow::Error>>>` to implement `Send`
[INFO] [stdout] note: required because it appears within the type `Box<impl Future<Output = Result<resp::Value, anyhow::Error>>>`
[INFO] [stdout]    --> /rustc/6cbf54b1453b438241487f195740266bb9d8c8ba/library/alloc/src/boxed.rs:231:12
[INFO] [stdout] note: required because it appears within the type `Pin<Box<impl Future<Output = Result<resp::Value, anyhow::Error>>>>`
[INFO] [stdout]    --> /rustc/6cbf54b1453b438241487f195740266bb9d8c8ba/library/core/src/pin.rs:1094:12
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> src/resp.rs:244:67
[INFO] [stdout]     |
[INFO] [stdout] 244 |       async fn parse_array(&mut self) -> anyhow::Result<Vec<Value>> {
[INFO] [stdout]     |  ___________________________________________________________________^
[INFO] [stdout] 245 | |         let len = self.parse_int().await?;
[INFO] [stdout] 246 | |         let mut arr = Vec::with_capacity(len as usize);
[INFO] [stdout] 247 | |         for _ in 0..len {
[INFO] [stdout] ...   |
[INFO] [stdout] 250 | |         Ok(arr)
[INFO] [stdout] 251 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> src/resp.rs:184:60
[INFO] [stdout]     |
[INFO] [stdout] 184 |       pub async fn parse(&mut self) -> anyhow::Result<Value> {
[INFO] [stdout]     |  ____________________________________________________________^
[INFO] [stdout] 185 | |         self.num_bytes += 1;
[INFO] [stdout] 186 | |         Ok(match self.input.read_u8().await? {
[INFO] [stdout] 187 | |             b'+' => match self.parse_simple_string().await? {
[INFO] [stdout] ...   |
[INFO] [stdout] 206 | |         })
[INFO] [stdout] 207 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout]     = note: required for `Unique<impl Future<Output = Result<resp::Value, anyhow::Error>>>` to implement `Send`
[INFO] [stdout] note: required because it appears within the type `Box<impl Future<Output = Result<resp::Value, anyhow::Error>>>`
[INFO] [stdout]    --> /rustc/6cbf54b1453b438241487f195740266bb9d8c8ba/library/alloc/src/boxed.rs:231:12
[INFO] [stdout] note: required because it appears within the type `Pin<Box<impl Future<Output = Result<resp::Value, anyhow::Error>>>>`
[INFO] [stdout]    --> /rustc/6cbf54b1453b438241487f195740266bb9d8c8ba/library/core/src/pin.rs:1094:12
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> src/resp.rs:244:67
[INFO] [stdout]     |
[INFO] [stdout] 244 |       async fn parse_array(&mut self) -> anyhow::Result<Vec<Value>> {
[INFO] [stdout]     |  ___________________________________________________________________^
[INFO] [stdout] 245 | |         let len = self.parse_int().await?;
[INFO] [stdout] 246 | |         let mut arr = Vec::with_capacity(len as usize);
[INFO] [stdout] 247 | |         for _ in 0..len {
[INFO] [stdout] ...   |
[INFO] [stdout] 250 | |         Ok(arr)
[INFO] [stdout] 251 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> src/resp.rs:184:60
[INFO] [stdout]     |
[INFO] [stdout] 184 |       pub async fn parse(&mut self) -> anyhow::Result<Value> {
[INFO] [stdout]     |  ____________________________________________________________^
[INFO] [stdout] 185 | |         self.num_bytes += 1;
[INFO] [stdout] 186 | |         Ok(match self.input.read_u8().await? {
[INFO] [stdout] 187 | |             b'+' => match self.parse_simple_string().await? {
[INFO] [stdout] ...   |
[INFO] [stdout] 206 | |         })
[INFO] [stdout] 207 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout]     = note: required for `Unique<impl Future<Output = Result<resp::Value, anyhow::Error>>>` to implement `Send`
[INFO] [stdout] note: required because it appears within the type `Box<impl Future<Output = Result<resp::Value, anyhow::Error>>>`
[INFO] [stdout]    --> /rustc/6cbf54b1453b438241487f195740266bb9d8c8ba/library/alloc/src/boxed.rs:231:12
[INFO] [stdout] note: required because it appears within the type `Pin<Box<impl Future<Output = Result<resp::Value, anyhow::Error>>>>`
[INFO] [stdout]    --> /rustc/6cbf54b1453b438241487f195740266bb9d8c8ba/library/core/src/pin.rs:1094:12
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> src/resp.rs:244:67
[INFO] [stdout]     |
[INFO] [stdout] 244 |       async fn parse_array(&mut self) -> anyhow::Result<Vec<Value>> {
[INFO] [stdout]     |  ___________________________________________________________________^
[INFO] [stdout] 245 | |         let len = self.parse_int().await?;
[INFO] [stdout] 246 | |         let mut arr = Vec::with_capacity(len as usize);
[INFO] [stdout] 247 | |         for _ in 0..len {
[INFO] [stdout] ...   |
[INFO] [stdout] 250 | |         Ok(arr)
[INFO] [stdout] 251 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> src/resp.rs:184:60
[INFO] [stdout]     |
[INFO] [stdout] 184 |       pub async fn parse(&mut self) -> anyhow::Result<Value> {
[INFO] [stdout]     |  ____________________________________________________________^
[INFO] [stdout] 185 | |         self.num_bytes += 1;
[INFO] [stdout] 186 | |         Ok(match self.input.read_u8().await? {
[INFO] [stdout] 187 | |             b'+' => match self.parse_simple_string().await? {
[INFO] [stdout] ...   |
[INFO] [stdout] 206 | |         })
[INFO] [stdout] 207 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout]     = note: required for `Unique<impl Future<Output = Result<resp::Value, anyhow::Error>>>` to implement `Send`
[INFO] [stdout] note: required because it appears within the type `Box<impl Future<Output = Result<resp::Value, anyhow::Error>>>`
[INFO] [stdout]    --> /rustc/6cbf54b1453b438241487f195740266bb9d8c8ba/library/alloc/src/boxed.rs:231:12
[INFO] [stdout] note: required because it appears within the type `Pin<Box<impl Future<Output = Result<resp::Value, anyhow::Error>>>>`
[INFO] [stdout]    --> /rustc/6cbf54b1453b438241487f195740266bb9d8c8ba/library/core/src/pin.rs:1094:12
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> src/resp.rs:244:67
[INFO] [stdout]     |
[INFO] [stdout] 244 |       async fn parse_array(&mut self) -> anyhow::Result<Vec<Value>> {
[INFO] [stdout]     |  ___________________________________________________________________^
[INFO] [stdout] 245 | |         let len = self.parse_int().await?;
[INFO] [stdout] 246 | |         let mut arr = Vec::with_capacity(len as usize);
[INFO] [stdout] 247 | |         for _ in 0..len {
[INFO] [stdout] ...   |
[INFO] [stdout] 250 | |         Ok(arr)
[INFO] [stdout] 251 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> src/resp.rs:184:60
[INFO] [stdout]     |
[INFO] [stdout] 184 |       pub async fn parse(&mut self) -> anyhow::Result<Value> {
[INFO] [stdout]     |  ____________________________________________________________^
[INFO] [stdout] 185 | |         self.num_bytes += 1;
[INFO] [stdout] 186 | |         Ok(match self.input.read_u8().await? {
[INFO] [stdout] 187 | |             b'+' => match self.parse_simple_string().await? {
[INFO] [stdout] ...   |
[INFO] [stdout] 206 | |         })
[INFO] [stdout] 207 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout]     = note: required for `Unique<impl Future<Output = Result<resp::Value, anyhow::Error>>>` to implement `Send`
[INFO] [stdout] note: required because it appears within the type `Box<impl Future<Output = Result<resp::Value, anyhow::Error>>>`
[INFO] [stdout]    --> /rustc/6cbf54b1453b438241487f195740266bb9d8c8ba/library/alloc/src/boxed.rs:231:12
[INFO] [stdout] note: required because it appears within the type `Pin<Box<impl Future<Output = Result<resp::Value, anyhow::Error>>>>`
[INFO] [stdout]    --> /rustc/6cbf54b1453b438241487f195740266bb9d8c8ba/library/core/src/pin.rs:1094:12
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> src/resp.rs:244:67
[INFO] [stdout]     |
[INFO] [stdout] 244 |       async fn parse_array(&mut self) -> anyhow::Result<Vec<Value>> {
[INFO] [stdout]     |  ___________________________________________________________________^
[INFO] [stdout] 245 | |         let len = self.parse_int().await?;
[INFO] [stdout] 246 | |         let mut arr = Vec::with_capacity(len as usize);
[INFO] [stdout] 247 | |         for _ in 0..len {
[INFO] [stdout] ...   |
[INFO] [stdout] 250 | |         Ok(arr)
[INFO] [stdout] 251 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> src/resp.rs:184:60
[INFO] [stdout]     |
[INFO] [stdout] 184 |       pub async fn parse(&mut self) -> anyhow::Result<Value> {
[INFO] [stdout]     |  ____________________________________________________________^
[INFO] [stdout] 185 | |         self.num_bytes += 1;
[INFO] [stdout] 186 | |         Ok(match self.input.read_u8().await? {
[INFO] [stdout] 187 | |             b'+' => match self.parse_simple_string().await? {
[INFO] [stdout] ...   |
[INFO] [stdout] 206 | |         })
[INFO] [stdout] 207 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout]     = note: required for `Unique<impl Future<Output = Result<resp::Value, anyhow::Error>>>` to implement `Send`
[INFO] [stdout] note: required because it appears within the type `Box<impl Future<Output = Result<resp::Value, anyhow::Error>>>`
[INFO] [stdout]    --> /rustc/6cbf54b1453b438241487f195740266bb9d8c8ba/library/alloc/src/boxed.rs:231:12
[INFO] [stdout] note: required because it appears within the type `Pin<Box<impl Future<Output = Result<resp::Value, anyhow::Error>>>>`
[INFO] [stdout]    --> /rustc/6cbf54b1453b438241487f195740266bb9d8c8ba/library/core/src/pin.rs:1094:12
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> src/resp.rs:244:67
[INFO] [stdout]     |
[INFO] [stdout] 244 |       async fn parse_array(&mut self) -> anyhow::Result<Vec<Value>> {
[INFO] [stdout]     |  ___________________________________________________________________^
[INFO] [stdout] 245 | |         let len = self.parse_int().await?;
[INFO] [stdout] 246 | |         let mut arr = Vec::with_capacity(len as usize);
[INFO] [stdout] 247 | |         for _ in 0..len {
[INFO] [stdout] ...   |
[INFO] [stdout] 250 | |         Ok(arr)
[INFO] [stdout] 251 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> src/resp.rs:184:60
[INFO] [stdout]     |
[INFO] [stdout] 184 |       pub async fn parse(&mut self) -> anyhow::Result<Value> {
[INFO] [stdout]     |  ____________________________________________________________^
[INFO] [stdout] 185 | |         self.num_bytes += 1;
[INFO] [stdout] 186 | |         Ok(match self.input.read_u8().await? {
[INFO] [stdout] 187 | |             b'+' => match self.parse_simple_string().await? {
[INFO] [stdout] ...   |
[INFO] [stdout] 206 | |         })
[INFO] [stdout] 207 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout]     = note: required for `Unique<impl Future<Output = Result<resp::Value, anyhow::Error>>>` to implement `Send`
[INFO] [stdout] note: required because it appears within the type `Box<impl Future<Output = Result<resp::Value, anyhow::Error>>>`
[INFO] [stdout]    --> /rustc/6cbf54b1453b438241487f195740266bb9d8c8ba/library/alloc/src/boxed.rs:231:12
[INFO] [stdout] note: required because it appears within the type `Pin<Box<impl Future<Output = Result<resp::Value, anyhow::Error>>>>`
[INFO] [stdout]    --> /rustc/6cbf54b1453b438241487f195740266bb9d8c8ba/library/core/src/pin.rs:1094:12
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> src/resp.rs:244:67
[INFO] [stdout]     |
[INFO] [stdout] 244 |       async fn parse_array(&mut self) -> anyhow::Result<Vec<Value>> {
[INFO] [stdout]     |  ___________________________________________________________________^
[INFO] [stdout] 245 | |         let len = self.parse_int().await?;
[INFO] [stdout] 246 | |         let mut arr = Vec::with_capacity(len as usize);
[INFO] [stdout] 247 | |         for _ in 0..len {
[INFO] [stdout] ...   |
[INFO] [stdout] 250 | |         Ok(arr)
[INFO] [stdout] 251 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> src/resp.rs:184:60
[INFO] [stdout]     |
[INFO] [stdout] 184 |       pub async fn parse(&mut self) -> anyhow::Result<Value> {
[INFO] [stdout]     |  ____________________________________________________________^
[INFO] [stdout] 185 | |         self.num_bytes += 1;
[INFO] [stdout] 186 | |         Ok(match self.input.read_u8().await? {
[INFO] [stdout] 187 | |             b'+' => match self.parse_simple_string().await? {
[INFO] [stdout] ...   |
[INFO] [stdout] 206 | |         })
[INFO] [stdout] 207 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout]     = note: required for `Unique<impl Future<Output = Result<resp::Value, anyhow::Error>>>` to implement `Send`
[INFO] [stdout] note: required because it appears within the type `Box<impl Future<Output = Result<resp::Value, anyhow::Error>>>`
[INFO] [stdout]    --> /rustc/6cbf54b1453b438241487f195740266bb9d8c8ba/library/alloc/src/boxed.rs:231:12
[INFO] [stdout] note: required because it appears within the type `Pin<Box<impl Future<Output = Result<resp::Value, anyhow::Error>>>>`
[INFO] [stdout]    --> /rustc/6cbf54b1453b438241487f195740266bb9d8c8ba/library/core/src/pin.rs:1094:12
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> src/resp.rs:244:67
[INFO] [stdout]     |
[INFO] [stdout] 244 |       async fn parse_array(&mut self) -> anyhow::Result<Vec<Value>> {
[INFO] [stdout]     |  ___________________________________________________________________^
[INFO] [stdout] 245 | |         let len = self.parse_int().await?;
[INFO] [stdout] 246 | |         let mut arr = Vec::with_capacity(len as usize);
[INFO] [stdout] 247 | |         for _ in 0..len {
[INFO] [stdout] ...   |
[INFO] [stdout] 250 | |         Ok(arr)
[INFO] [stdout] 251 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> src/resp.rs:184:60
[INFO] [stdout]     |
[INFO] [stdout] 184 |       pub async fn parse(&mut self) -> anyhow::Result<Value> {
[INFO] [stdout]     |  ____________________________________________________________^
[INFO] [stdout] 185 | |         self.num_bytes += 1;
[INFO] [stdout] 186 | |         Ok(match self.input.read_u8().await? {
[INFO] [stdout] 187 | |             b'+' => match self.parse_simple_string().await? {
[INFO] [stdout] ...   |
[INFO] [stdout] 206 | |         })
[INFO] [stdout] 207 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout]     = note: required for `Unique<impl Future<Output = Result<resp::Value, anyhow::Error>>>` to implement `Send`
[INFO] [stdout] note: required because it appears within the type `Box<impl Future<Output = Result<resp::Value, anyhow::Error>>>`
[INFO] [stdout]    --> /rustc/6cbf54b1453b438241487f195740266bb9d8c8ba/library/alloc/src/boxed.rs:231:12
[INFO] [stdout] note: required because it appears within the type `Pin<Box<impl Future<Output = Result<resp::Value, anyhow::Error>>>>`
[INFO] [stdout]    --> /rustc/6cbf54b1453b438241487f195740266bb9d8c8ba/library/core/src/pin.rs:1094:12
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> src/resp.rs:244:67
[INFO] [stdout]     |
[INFO] [stdout] 244 |       async fn parse_array(&mut self) -> anyhow::Result<Vec<Value>> {
[INFO] [stdout]     |  ___________________________________________________________________^
[INFO] [stdout] 245 | |         let len = self.parse_int().await?;
[INFO] [stdout] 246 | |         let mut arr = Vec::with_capacity(len as usize);
[INFO] [stdout] 247 | |         for _ in 0..len {
[INFO] [stdout] ...   |
[INFO] [stdout] 250 | |         Ok(arr)
[INFO] [stdout] 251 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> src/resp.rs:184:60
[INFO] [stdout]     |
[INFO] [stdout] 184 |       pub async fn parse(&mut self) -> anyhow::Result<Value> {
[INFO] [stdout]     |  ____________________________________________________________^
[INFO] [stdout] 185 | |         self.num_bytes += 1;
[INFO] [stdout] 186 | |         Ok(match self.input.read_u8().await? {
[INFO] [stdout] 187 | |             b'+' => match self.parse_simple_string().await? {
[INFO] [stdout] ...   |
[INFO] [stdout] 206 | |         })
[INFO] [stdout] 207 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> src/resp.rs:266:37
[INFO] [stdout]     |
[INFO] [stdout] 266 |   ) -> anyhow::Result<(Value, usize)> {
[INFO] [stdout]     |  _____________________________________^
[INFO] [stdout] 267 | |     let mut de = Deserializer::new(reader);
[INFO] [stdout] 268 | |     Ok((
[INFO] [stdout] 269 | |         de.parse()
[INFO] [stdout] ...   |
[INFO] [stdout] 273 | |     ))
[INFO] [stdout] 274 | | }
[INFO] [stdout]     | |_^
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> src/main.rs:181:93
[INFO] [stdout]     |
[INFO] [stdout] 181 |   async fn replica_handshake(master: SocketAddr, state: &'static State) -> anyhow::Result<()> {
[INFO] [stdout]     |  _____________________________________________________________________________________________^
[INFO] [stdout] 182 | |     println!("Starting handshake...");
[INFO] [stdout] 183 | |
[INFO] [stdout] 184 | |     let (read_half, mut writer) = TcpStream::connect(master).await?.into_split();
[INFO] [stdout] ...   |
[INFO] [stdout] 251 | |     Ok(())
[INFO] [stdout] 252 | | }
[INFO] [stdout]     | |_^
[INFO] [stdout] note: required by a bound in `tokio::spawn`
[INFO] [stdout]    --> /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.38.0/src/task/spawn.rs:166:21
[INFO] [stdout]     |
[INFO] [stdout] 164 |     pub fn spawn<F>(future: F) -> JoinHandle<F::Output>
[INFO] [stdout]     |            ----- required by a bound in this function
[INFO] [stdout] 165 |     where
[INFO] [stdout] 166 |         F: Future + Send + 'static,
[INFO] [stdout]     |                     ^^^^ required by this bound in `spawn`
[INFO] [stdout]     = note: the full name for the type has been written to '/opt/rustwide/target/debug/deps/redis_starter_rust-c8bd79cacc286cc4.long-type-436959172805894477.txt'
[INFO] [stdout]     = note: consider using `--verbose` to print the full type name to the console
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0275]: overflow evaluating the requirement `&mut Deserializer<'_, tokio::io::BufReader<tokio::net::tcp::OwnedReadHalf>>: Send`
[INFO] [stdout]    --> src/main.rs:50:9
[INFO] [stdout]     |
[INFO] [stdout] 50  |         tokio::spawn(replica_handshake(master, state));
[INFO] [stdout]     |         ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = help: consider increasing the recursion limit by adding a `#![recursion_limit = "256"]` attribute to your crate (`redis_starter_rust`)
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> src/resp.rs:220:79
[INFO] [stdout]     |
[INFO] [stdout] 220 |       async fn parse_simple_string(&mut self) -> anyhow::Result<Option<String>> {
[INFO] [stdout]     |  _______________________________________________________________________________^
[INFO] [stdout] 221 | |         let mut buf = vec![];
[INFO] [stdout] 222 | |         self.input.read_until(b'\n', &mut buf).await?;
[INFO] [stdout] ...   |
[INFO] [stdout] 229 | |         Ok(if str == "OK" { None } else { Some(str) })
[INFO] [stdout] 230 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> src/resp.rs:184:60
[INFO] [stdout]     |
[INFO] [stdout] 184 |       pub async fn parse(&mut self) -> anyhow::Result<Value> {
[INFO] [stdout]     |  ____________________________________________________________^
[INFO] [stdout] 185 | |         self.num_bytes += 1;
[INFO] [stdout] 186 | |         Ok(match self.input.read_u8().await? {
[INFO] [stdout] 187 | |             b'+' => match self.parse_simple_string().await? {
[INFO] [stdout] ...   |
[INFO] [stdout] 206 | |         })
[INFO] [stdout] 207 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout]     = note: required for `Unique<impl Future<Output = Result<resp::Value, anyhow::Error>>>` to implement `Send`
[INFO] [stdout] note: required because it appears within the type `Box<impl Future<Output = Result<resp::Value, anyhow::Error>>>`
[INFO] [stdout]    --> /rustc/6cbf54b1453b438241487f195740266bb9d8c8ba/library/alloc/src/boxed.rs:231:12
[INFO] [stdout] note: required because it appears within the type `Pin<Box<impl Future<Output = Result<resp::Value, anyhow::Error>>>>`
[INFO] [stdout]    --> /rustc/6cbf54b1453b438241487f195740266bb9d8c8ba/library/core/src/pin.rs:1094:12
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> src/resp.rs:244:67
[INFO] [stdout]     |
[INFO] [stdout] 244 |       async fn parse_array(&mut self) -> anyhow::Result<Vec<Value>> {
[INFO] [stdout]     |  ___________________________________________________________________^
[INFO] [stdout] 245 | |         let len = self.parse_int().await?;
[INFO] [stdout] 246 | |         let mut arr = Vec::with_capacity(len as usize);
[INFO] [stdout] 247 | |         for _ in 0..len {
[INFO] [stdout] ...   |
[INFO] [stdout] 250 | |         Ok(arr)
[INFO] [stdout] 251 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> src/resp.rs:184:60
[INFO] [stdout]     |
[INFO] [stdout] 184 |       pub async fn parse(&mut self) -> anyhow::Result<Value> {
[INFO] [stdout]     |  ____________________________________________________________^
[INFO] [stdout] 185 | |         self.num_bytes += 1;
[INFO] [stdout] 186 | |         Ok(match self.input.read_u8().await? {
[INFO] [stdout] 187 | |             b'+' => match self.parse_simple_string().await? {
[INFO] [stdout] ...   |
[INFO] [stdout] 206 | |         })
[INFO] [stdout] 207 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout]     = note: required for `Unique<impl Future<Output = Result<resp::Value, anyhow::Error>>>` to implement `Send`
[INFO] [stdout] note: required because it appears within the type `Box<impl Future<Output = Result<resp::Value, anyhow::Error>>>`
[INFO] [stdout]    --> /rustc/6cbf54b1453b438241487f195740266bb9d8c8ba/library/alloc/src/boxed.rs:231:12
[INFO] [stdout] note: required because it appears within the type `Pin<Box<impl Future<Output = Result<resp::Value, anyhow::Error>>>>`
[INFO] [stdout]    --> /rustc/6cbf54b1453b438241487f195740266bb9d8c8ba/library/core/src/pin.rs:1094:12
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> src/resp.rs:244:67
[INFO] [stdout]     |
[INFO] [stdout] 244 |       async fn parse_array(&mut self) -> anyhow::Result<Vec<Value>> {
[INFO] [stdout]     |  ___________________________________________________________________^
[INFO] [stdout] 245 | |         let len = self.parse_int().await?;
[INFO] [stdout] 246 | |         let mut arr = Vec::with_capacity(len as usize);
[INFO] [stdout] 247 | |         for _ in 0..len {
[INFO] [stdout] ...   |
[INFO] [stdout] 250 | |         Ok(arr)
[INFO] [stdout] 251 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> src/resp.rs:184:60
[INFO] [stdout]     |
[INFO] [stdout] 184 |       pub async fn parse(&mut self) -> anyhow::Result<Value> {
[INFO] [stdout]     |  ____________________________________________________________^
[INFO] [stdout] 185 | |         self.num_bytes += 1;
[INFO] [stdout] 186 | |         Ok(match self.input.read_u8().await? {
[INFO] [stdout] 187 | |             b'+' => match self.parse_simple_string().await? {
[INFO] [stdout] ...   |
[INFO] [stdout] 206 | |         })
[INFO] [stdout] 207 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout]     = note: required for `Unique<impl Future<Output = Result<resp::Value, anyhow::Error>>>` to implement `Send`
[INFO] [stdout] note: required because it appears within the type `Box<impl Future<Output = Result<resp::Value, anyhow::Error>>>`
[INFO] [stdout]    --> /rustc/6cbf54b1453b438241487f195740266bb9d8c8ba/library/alloc/src/boxed.rs:231:12
[INFO] [stdout] note: required because it appears within the type `Pin<Box<impl Future<Output = Result<resp::Value, anyhow::Error>>>>`
[INFO] [stdout]    --> /rustc/6cbf54b1453b438241487f195740266bb9d8c8ba/library/core/src/pin.rs:1094:12
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> src/resp.rs:244:67
[INFO] [stdout]     |
[INFO] [stdout] 244 |       async fn parse_array(&mut self) -> anyhow::Result<Vec<Value>> {
[INFO] [stdout]     |  ___________________________________________________________________^
[INFO] [stdout] 245 | |         let len = self.parse_int().await?;
[INFO] [stdout] 246 | |         let mut arr = Vec::with_capacity(len as usize);
[INFO] [stdout] 247 | |         for _ in 0..len {
[INFO] [stdout] ...   |
[INFO] [stdout] 250 | |         Ok(arr)
[INFO] [stdout] 251 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> src/resp.rs:184:60
[INFO] [stdout]     |
[INFO] [stdout] 184 |       pub async fn parse(&mut self) -> anyhow::Result<Value> {
[INFO] [stdout]     |  ____________________________________________________________^
[INFO] [stdout] 185 | |         self.num_bytes += 1;
[INFO] [stdout] 186 | |         Ok(match self.input.read_u8().await? {
[INFO] [stdout] 187 | |             b'+' => match self.parse_simple_string().await? {
[INFO] [stdout] ...   |
[INFO] [stdout] 206 | |         })
[INFO] [stdout] 207 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout]     = note: required for `Unique<impl Future<Output = Result<resp::Value, anyhow::Error>>>` to implement `Send`
[INFO] [stdout] note: required because it appears within the type `Box<impl Future<Output = Result<resp::Value, anyhow::Error>>>`
[INFO] [stdout]    --> /rustc/6cbf54b1453b438241487f195740266bb9d8c8ba/library/alloc/src/boxed.rs:231:12
[INFO] [stdout] note: required because it appears within the type `Pin<Box<impl Future<Output = Result<resp::Value, anyhow::Error>>>>`
[INFO] [stdout]    --> /rustc/6cbf54b1453b438241487f195740266bb9d8c8ba/library/core/src/pin.rs:1094:12
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> src/resp.rs:244:67
[INFO] [stdout]     |
[INFO] [stdout] 244 |       async fn parse_array(&mut self) -> anyhow::Result<Vec<Value>> {
[INFO] [stdout]     |  ___________________________________________________________________^
[INFO] [stdout] 245 | |         let len = self.parse_int().await?;
[INFO] [stdout] 246 | |         let mut arr = Vec::with_capacity(len as usize);
[INFO] [stdout] 247 | |         for _ in 0..len {
[INFO] [stdout] ...   |
[INFO] [stdout] 250 | |         Ok(arr)
[INFO] [stdout] 251 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> src/resp.rs:184:60
[INFO] [stdout]     |
[INFO] [stdout] 184 |       pub async fn parse(&mut self) -> anyhow::Result<Value> {
[INFO] [stdout]     |  ____________________________________________________________^
[INFO] [stdout] 185 | |         self.num_bytes += 1;
[INFO] [stdout] 186 | |         Ok(match self.input.read_u8().await? {
[INFO] [stdout] 187 | |             b'+' => match self.parse_simple_string().await? {
[INFO] [stdout] ...   |
[INFO] [stdout] 206 | |         })
[INFO] [stdout] 207 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout]     = note: required for `Unique<impl Future<Output = Result<resp::Value, anyhow::Error>>>` to implement `Send`
[INFO] [stdout] note: required because it appears within the type `Box<impl Future<Output = Result<resp::Value, anyhow::Error>>>`
[INFO] [stdout]    --> /rustc/6cbf54b1453b438241487f195740266bb9d8c8ba/library/alloc/src/boxed.rs:231:12
[INFO] [stdout] note: required because it appears within the type `Pin<Box<impl Future<Output = Result<resp::Value, anyhow::Error>>>>`
[INFO] [stdout]    --> /rustc/6cbf54b1453b438241487f195740266bb9d8c8ba/library/core/src/pin.rs:1094:12
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> src/resp.rs:244:67
[INFO] [stdout]     |
[INFO] [stdout] 244 |       async fn parse_array(&mut self) -> anyhow::Result<Vec<Value>> {
[INFO] [stdout]     |  ___________________________________________________________________^
[INFO] [stdout] 245 | |         let len = self.parse_int().await?;
[INFO] [stdout] 246 | |         let mut arr = Vec::with_capacity(len as usize);
[INFO] [stdout] 247 | |         for _ in 0..len {
[INFO] [stdout] ...   |
[INFO] [stdout] 250 | |         Ok(arr)
[INFO] [stdout] 251 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> src/resp.rs:184:60
[INFO] [stdout]     |
[INFO] [stdout] 184 |       pub async fn parse(&mut self) -> anyhow::Result<Value> {
[INFO] [stdout]     |  ____________________________________________________________^
[INFO] [stdout] 185 | |         self.num_bytes += 1;
[INFO] [stdout] 186 | |         Ok(match self.input.read_u8().await? {
[INFO] [stdout] 187 | |             b'+' => match self.parse_simple_string().await? {
[INFO] [stdout] ...   |
[INFO] [stdout] 206 | |         })
[INFO] [stdout] 207 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout]     = note: required for `Unique<impl Future<Output = Result<resp::Value, anyhow::Error>>>` to implement `Send`
[INFO] [stdout] note: required because it appears within the type `Box<impl Future<Output = Result<resp::Value, anyhow::Error>>>`
[INFO] [stdout]    --> /rustc/6cbf54b1453b438241487f195740266bb9d8c8ba/library/alloc/src/boxed.rs:231:12
[INFO] [stdout] note: required because it appears within the type `Pin<Box<impl Future<Output = Result<resp::Value, anyhow::Error>>>>`
[INFO] [stdout]    --> /rustc/6cbf54b1453b438241487f195740266bb9d8c8ba/library/core/src/pin.rs:1094:12
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> src/resp.rs:244:67
[INFO] [stdout]     |
[INFO] [stdout] 244 |       async fn parse_array(&mut self) -> anyhow::Result<Vec<Value>> {
[INFO] [stdout]     |  ___________________________________________________________________^
[INFO] [stdout] 245 | |         let len = self.parse_int().await?;
[INFO] [stdout] 246 | |         let mut arr = Vec::with_capacity(len as usize);
[INFO] [stdout] 247 | |         for _ in 0..len {
[INFO] [stdout] ...   |
[INFO] [stdout] 250 | |         Ok(arr)
[INFO] [stdout] 251 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> src/resp.rs:184:60
[INFO] [stdout]     |
[INFO] [stdout] 184 |       pub async fn parse(&mut self) -> anyhow::Result<Value> {
[INFO] [stdout]     |  ____________________________________________________________^
[INFO] [stdout] 185 | |         self.num_bytes += 1;
[INFO] [stdout] 186 | |         Ok(match self.input.read_u8().await? {
[INFO] [stdout] 187 | |             b'+' => match self.parse_simple_string().await? {
[INFO] [stdout] ...   |
[INFO] [stdout] 206 | |         })
[INFO] [stdout] 207 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout]     = note: required for `Unique<impl Future<Output = Result<resp::Value, anyhow::Error>>>` to implement `Send`
[INFO] [stdout] note: required because it appears within the type `Box<impl Future<Output = Result<resp::Value, anyhow::Error>>>`
[INFO] [stdout]    --> /rustc/6cbf54b1453b438241487f195740266bb9d8c8ba/library/alloc/src/boxed.rs:231:12
[INFO] [stdout] note: required because it appears within the type `Pin<Box<impl Future<Output = Result<resp::Value, anyhow::Error>>>>`
[INFO] [stdout]    --> /rustc/6cbf54b1453b438241487f195740266bb9d8c8ba/library/core/src/pin.rs:1094:12
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> src/resp.rs:244:67
[INFO] [stdout]     |
[INFO] [stdout] 244 |       async fn parse_array(&mut self) -> anyhow::Result<Vec<Value>> {
[INFO] [stdout]     |  ___________________________________________________________________^
[INFO] [stdout] 245 | |         let len = self.parse_int().await?;
[INFO] [stdout] 246 | |         let mut arr = Vec::with_capacity(len as usize);
[INFO] [stdout] 247 | |         for _ in 0..len {
[INFO] [stdout] ...   |
[INFO] [stdout] 250 | |         Ok(arr)
[INFO] [stdout] 251 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> src/resp.rs:184:60
[INFO] [stdout]     |
[INFO] [stdout] 184 |       pub async fn parse(&mut self) -> anyhow::Result<Value> {
[INFO] [stdout]     |  ____________________________________________________________^
[INFO] [stdout] 185 | |         self.num_bytes += 1;
[INFO] [stdout] 186 | |         Ok(match self.input.read_u8().await? {
[INFO] [stdout] 187 | |             b'+' => match self.parse_simple_string().await? {
[INFO] [stdout] ...   |
[INFO] [stdout] 206 | |         })
[INFO] [stdout] 207 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout]     = note: required for `Unique<impl Future<Output = Result<resp::Value, anyhow::Error>>>` to implement `Send`
[INFO] [stdout] note: required because it appears within the type `Box<impl Future<Output = Result<resp::Value, anyhow::Error>>>`
[INFO] [stdout]    --> /rustc/6cbf54b1453b438241487f195740266bb9d8c8ba/library/alloc/src/boxed.rs:231:12
[INFO] [stdout] note: required because it appears within the type `Pin<Box<impl Future<Output = Result<resp::Value, anyhow::Error>>>>`
[INFO] [stdout]    --> /rustc/6cbf54b1453b438241487f195740266bb9d8c8ba/library/core/src/pin.rs:1094:12
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> src/resp.rs:244:67
[INFO] [stdout]     |
[INFO] [stdout] 244 |       async fn parse_array(&mut self) -> anyhow::Result<Vec<Value>> {
[INFO] [stdout]     |  ___________________________________________________________________^
[INFO] [stdout] 245 | |         let len = self.parse_int().await?;
[INFO] [stdout] 246 | |         let mut arr = Vec::with_capacity(len as usize);
[INFO] [stdout] 247 | |         for _ in 0..len {
[INFO] [stdout] ...   |
[INFO] [stdout] 250 | |         Ok(arr)
[INFO] [stdout] 251 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> src/resp.rs:184:60
[INFO] [stdout]     |
[INFO] [stdout] 184 |       pub async fn parse(&mut self) -> anyhow::Result<Value> {
[INFO] [stdout]     |  ____________________________________________________________^
[INFO] [stdout] 185 | |         self.num_bytes += 1;
[INFO] [stdout] 186 | |         Ok(match self.input.read_u8().await? {
[INFO] [stdout] 187 | |             b'+' => match self.parse_simple_string().await? {
[INFO] [stdout] ...   |
[INFO] [stdout] 206 | |         })
[INFO] [stdout] 207 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout]     = note: required for `Unique<impl Future<Output = Result<resp::Value, anyhow::Error>>>` to implement `Send`
[INFO] [stdout] note: required because it appears within the type `Box<impl Future<Output = Result<resp::Value, anyhow::Error>>>`
[INFO] [stdout]    --> /rustc/6cbf54b1453b438241487f195740266bb9d8c8ba/library/alloc/src/boxed.rs:231:12
[INFO] [stdout] note: required because it appears within the type `Pin<Box<impl Future<Output = Result<resp::Value, anyhow::Error>>>>`
[INFO] [stdout]    --> /rustc/6cbf54b1453b438241487f195740266bb9d8c8ba/library/core/src/pin.rs:1094:12
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> src/resp.rs:244:67
[INFO] [stdout]     |
[INFO] [stdout] 244 |       async fn parse_array(&mut self) -> anyhow::Result<Vec<Value>> {
[INFO] [stdout]     |  ___________________________________________________________________^
[INFO] [stdout] 245 | |         let len = self.parse_int().await?;
[INFO] [stdout] 246 | |         let mut arr = Vec::with_capacity(len as usize);
[INFO] [stdout] 247 | |         for _ in 0..len {
[INFO] [stdout] ...   |
[INFO] [stdout] 250 | |         Ok(arr)
[INFO] [stdout] 251 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> src/resp.rs:184:60
[INFO] [stdout]     |
[INFO] [stdout] 184 |       pub async fn parse(&mut self) -> anyhow::Result<Value> {
[INFO] [stdout]     |  ____________________________________________________________^
[INFO] [stdout] 185 | |         self.num_bytes += 1;
[INFO] [stdout] 186 | |         Ok(match self.input.read_u8().await? {
[INFO] [stdout] 187 | |             b'+' => match self.parse_simple_string().await? {
[INFO] [stdout] ...   |
[INFO] [stdout] 206 | |         })
[INFO] [stdout] 207 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout]     = note: required for `Unique<impl Future<Output = Result<resp::Value, anyhow::Error>>>` to implement `Send`
[INFO] [stdout] note: required because it appears within the type `Box<impl Future<Output = Result<resp::Value, anyhow::Error>>>`
[INFO] [stdout]    --> /rustc/6cbf54b1453b438241487f195740266bb9d8c8ba/library/alloc/src/boxed.rs:231:12
[INFO] [stdout] note: required because it appears within the type `Pin<Box<impl Future<Output = Result<resp::Value, anyhow::Error>>>>`
[INFO] [stdout]    --> /rustc/6cbf54b1453b438241487f195740266bb9d8c8ba/library/core/src/pin.rs:1094:12
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> src/resp.rs:244:67
[INFO] [stdout]     |
[INFO] [stdout] 244 |       async fn parse_array(&mut self) -> anyhow::Result<Vec<Value>> {
[INFO] [stdout]     |  ___________________________________________________________________^
[INFO] [stdout] 245 | |         let len = self.parse_int().await?;
[INFO] [stdout] 246 | |         let mut arr = Vec::with_capacity(len as usize);
[INFO] [stdout] 247 | |         for _ in 0..len {
[INFO] [stdout] ...   |
[INFO] [stdout] 250 | |         Ok(arr)
[INFO] [stdout] 251 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> src/resp.rs:184:60
[INFO] [stdout]     |
[INFO] [stdout] 184 |       pub async fn parse(&mut self) -> anyhow::Result<Value> {
[INFO] [stdout]     |  ____________________________________________________________^
[INFO] [stdout] 185 | |         self.num_bytes += 1;
[INFO] [stdout] 186 | |         Ok(match self.input.read_u8().await? {
[INFO] [stdout] 187 | |             b'+' => match self.parse_simple_string().await? {
[INFO] [stdout] ...   |
[INFO] [stdout] 206 | |         })
[INFO] [stdout] 207 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout]     = note: required for `Unique<impl Future<Output = Result<resp::Value, anyhow::Error>>>` to implement `Send`
[INFO] [stdout] note: required because it appears within the type `Box<impl Future<Output = Result<resp::Value, anyhow::Error>>>`
[INFO] [stdout]    --> /rustc/6cbf54b1453b438241487f195740266bb9d8c8ba/library/alloc/src/boxed.rs:231:12
[INFO] [stdout] note: required because it appears within the type `Pin<Box<impl Future<Output = Result<resp::Value, anyhow::Error>>>>`
[INFO] [stdout]    --> /rustc/6cbf54b1453b438241487f195740266bb9d8c8ba/library/core/src/pin.rs:1094:12
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> src/resp.rs:244:67
[INFO] [stdout]     |
[INFO] [stdout] 244 |       async fn parse_array(&mut self) -> anyhow::Result<Vec<Value>> {
[INFO] [stdout]     |  ___________________________________________________________________^
[INFO] [stdout] 245 | |         let len = self.parse_int().await?;
[INFO] [stdout] 246 | |         let mut arr = Vec::with_capacity(len as usize);
[INFO] [stdout] 247 | |         for _ in 0..len {
[INFO] [stdout] ...   |
[INFO] [stdout] 250 | |         Ok(arr)
[INFO] [stdout] 251 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> src/resp.rs:184:60
[INFO] [stdout]     |
[INFO] [stdout] 184 |       pub async fn parse(&mut self) -> anyhow::Result<Value> {
[INFO] [stdout]     |  ____________________________________________________________^
[INFO] [stdout] 185 | |         self.num_bytes += 1;
[INFO] [stdout] 186 | |         Ok(match self.input.read_u8().await? {
[INFO] [stdout] 187 | |             b'+' => match self.parse_simple_string().await? {
[INFO] [stdout] ...   |
[INFO] [stdout] 206 | |         })
[INFO] [stdout] 207 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout]     = note: required for `Unique<impl Future<Output = Result<resp::Value, anyhow::Error>>>` to implement `Send`
[INFO] [stdout] note: required because it appears within the type `Box<impl Future<Output = Result<resp::Value, anyhow::Error>>>`
[INFO] [stdout]    --> /rustc/6cbf54b1453b438241487f195740266bb9d8c8ba/library/alloc/src/boxed.rs:231:12
[INFO] [stdout] note: required because it appears within the type `Pin<Box<impl Future<Output = Result<resp::Value, anyhow::Error>>>>`
[INFO] [stdout]    --> /rustc/6cbf54b1453b438241487f195740266bb9d8c8ba/library/core/src/pin.rs:1094:12
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> src/resp.rs:244:67
[INFO] [stdout]     |
[INFO] [stdout] 244 |       async fn parse_array(&mut self) -> anyhow::Result<Vec<Value>> {
[INFO] [stdout]     |  ___________________________________________________________________^
[INFO] [stdout] 245 | |         let len = self.parse_int().await?;
[INFO] [stdout] 246 | |         let mut arr = Vec::with_capacity(len as usize);
[INFO] [stdout] 247 | |         for _ in 0..len {
[INFO] [stdout] ...   |
[INFO] [stdout] 250 | |         Ok(arr)
[INFO] [stdout] 251 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> src/resp.rs:184:60
[INFO] [stdout]     |
[INFO] [stdout] 184 |       pub async fn parse(&mut self) -> anyhow::Result<Value> {
[INFO] [stdout]     |  ____________________________________________________________^
[INFO] [stdout] 185 | |         self.num_bytes += 1;
[INFO] [stdout] 186 | |         Ok(match self.input.read_u8().await? {
[INFO] [stdout] 187 | |             b'+' => match self.parse_simple_string().await? {
[INFO] [stdout] ...   |
[INFO] [stdout] 206 | |         })
[INFO] [stdout] 207 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout]     = note: required for `Unique<impl Future<Output = Result<resp::Value, anyhow::Error>>>` to implement `Send`
[INFO] [stdout] note: required because it appears within the type `Box<impl Future<Output = Result<resp::Value, anyhow::Error>>>`
[INFO] [stdout]    --> /rustc/6cbf54b1453b438241487f195740266bb9d8c8ba/library/alloc/src/boxed.rs:231:12
[INFO] [stdout] note: required because it appears within the type `Pin<Box<impl Future<Output = Result<resp::Value, anyhow::Error>>>>`
[INFO] [stdout]    --> /rustc/6cbf54b1453b438241487f195740266bb9d8c8ba/library/core/src/pin.rs:1094:12
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> src/resp.rs:244:67
[INFO] [stdout]     |
[INFO] [stdout] 244 |       async fn parse_array(&mut self) -> anyhow::Result<Vec<Value>> {
[INFO] [stdout]     |  ___________________________________________________________________^
[INFO] [stdout] 245 | |         let len = self.parse_int().await?;
[INFO] [stdout] 246 | |         let mut arr = Vec::with_capacity(len as usize);
[INFO] [stdout] 247 | |         for _ in 0..len {
[INFO] [stdout] ...   |
[INFO] [stdout] 250 | |         Ok(arr)
[INFO] [stdout] 251 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> src/resp.rs:184:60
[INFO] [stdout]     |
[INFO] [stdout] 184 |       pub async fn parse(&mut self) -> anyhow::Result<Value> {
[INFO] [stdout]     |  ____________________________________________________________^
[INFO] [stdout] 185 | |         self.num_bytes += 1;
[INFO] [stdout] 186 | |         Ok(match self.input.read_u8().await? {
[INFO] [stdout] 187 | |             b'+' => match self.parse_simple_string().await? {
[INFO] [stdout] ...   |
[INFO] [stdout] 206 | |         })
[INFO] [stdout] 207 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> src/resp.rs:266:37
[INFO] [stdout]     |
[INFO] [stdout] 266 |   ) -> anyhow::Result<(Value, usize)> {
[INFO] [stdout]     |  _____________________________________^
[INFO] [stdout] 267 | |     let mut de = Deserializer::new(reader);
[INFO] [stdout] 268 | |     Ok((
[INFO] [stdout] 269 | |         de.parse()
[INFO] [stdout] ...   |
[INFO] [stdout] 273 | |     ))
[INFO] [stdout] 274 | | }
[INFO] [stdout]     | |_^
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> src/main.rs:181:93
[INFO] [stdout]     |
[INFO] [stdout] 181 |   async fn replica_handshake(master: SocketAddr, state: &'static State) -> anyhow::Result<()> {
[INFO] [stdout]     |  _____________________________________________________________________________________________^
[INFO] [stdout] 182 | |     println!("Starting handshake...");
[INFO] [stdout] 183 | |
[INFO] [stdout] 184 | |     let (read_half, mut writer) = TcpStream::connect(master).await?.into_split();
[INFO] [stdout] ...   |
[INFO] [stdout] 251 | |     Ok(())
[INFO] [stdout] 252 | | }
[INFO] [stdout]     | |_^
[INFO] [stdout] note: required by a bound in `tokio::spawn`
[INFO] [stdout]    --> /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.38.0/src/task/spawn.rs:166:21
[INFO] [stdout]     |
[INFO] [stdout] 164 |     pub fn spawn<F>(future: F) -> JoinHandle<F::Output>
[INFO] [stdout]     |            ----- required by a bound in this function
[INFO] [stdout] 165 |     where
[INFO] [stdout] 166 |         F: Future + Send + 'static,
[INFO] [stdout]     |                     ^^^^ required by this bound in `spawn`
[INFO] [stdout]     = note: the full name for the type has been written to '/opt/rustwide/target/debug/deps/redis_starter_rust-a47975c930e2f9d5.long-type-12090684704557814944.txt'
[INFO] [stdout]     = note: consider using `--verbose` to print the full type name to the console
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] For more information about this error, try `rustc --explain E0275`.
[INFO] [stdout] 
[INFO] [stdout] For more information about this error, try `rustc --explain E0275`.
[INFO] [stdout] 
[INFO] [stderr] error: could not compile `redis-starter-rust` (bin "redis-starter-rust") due to 1 previous error
[INFO] [stderr] warning: build failed, waiting for other jobs to finish...
[INFO] [stderr] error: could not compile `redis-starter-rust` (bin "redis-starter-rust" test) due to 1 previous error
[INFO] running `Command { std: "docker" "inspect" "54cdc28b1412daa0adc219cf2b77e1b868ed79eb071f5e71a7c11f53c7db6504", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "54cdc28b1412daa0adc219cf2b77e1b868ed79eb071f5e71a7c11f53c7db6504", kill_on_drop: false }`
[INFO] [stdout] 54cdc28b1412daa0adc219cf2b77e1b868ed79eb071f5e71a7c11f53c7db6504