diff --git a/hole-punching-tests/src/main.rs b/hole-punching-tests/src/main.rs index f09fbb1e6a0..bbecc948e08 100644 --- a/hole-punching-tests/src/main.rs +++ b/hole-punching-tests/src/main.rs @@ -294,9 +294,7 @@ impl RedisClient { tracing::debug!("Pushing {key}={value} to redis"); - self.inner.rpush(key, value).await?; - - Ok(()) + self.inner.rpush(key, value).await.map_err(Into::into) } async fn pop(&mut self, key: &str) -> Result diff --git a/interop-tests/src/arch.rs b/interop-tests/src/arch.rs index fb229434981..a7755b95977 100644 --- a/interop-tests/src/arch.rs +++ b/interop-tests/src/arch.rs @@ -179,8 +179,7 @@ pub(crate) mod native { pub(crate) async fn rpush(&self, key: &str, value: String) -> Result<()> { let mut conn = self.0.get_async_connection().await?; - conn.rpush(key, value).await?; - Ok(()) + conn.rpush(key, value).await.map_err(Into::into) } } } diff --git a/protocols/ping/src/protocol.rs b/protocols/ping/src/protocol.rs index 9b4d7da98db..8fc18505d35 100644 --- a/protocols/ping/src/protocol.rs +++ b/protocols/ping/src/protocol.rs @@ -44,8 +44,7 @@ pub const PROTOCOL_NAME: StreamProtocol = StreamProtocol::new("/ipfs/ping/1.0.0" /// > Nagle's algorithm, delayed acks and similar configuration options /// > which can affect latencies especially on otherwise low-volume /// > connections. -#[derive(Default, Debug, Copy, Clone)] -pub(crate) struct Ping; + const PING_SIZE: usize = 32; /// Sends a ping and waits for the pong.