diff --git a/src/tests/util/chaosproxy.rs b/src/tests/util/chaosproxy.rs index 6c0b5ce08c2..d502dfe6fc0 100644 --- a/src/tests/util/chaosproxy.rs +++ b/src/tests/util/chaosproxy.rs @@ -129,7 +129,7 @@ impl ChaosProxy { // EOF, the socket was closed return Ok(()); } - to.write(&buf[0..len]).await?; + to.write_all(&buf[0..len]).await?; } _ = break_connections_recv.recv() => { to.shutdown().await?;