diff --git a/crates/integration-tests/src/test_peer.rs b/crates/integration-tests/src/test_peer.rs index 685ec1d..1b99bb8 100644 --- a/crates/integration-tests/src/test_peer.rs +++ b/crates/integration-tests/src/test_peer.rs @@ -86,7 +86,7 @@ impl TestPeer { pub async fn recv_within(&mut self, wait: Duration) -> Result { match tokio::time::timeout(wait, self.recv_untimed()).await { Ok(message) => message, - Err(_) => bail!("no message from the server within {wait:?}"), + Err(_) => Err(eyre::eyre!("no message from the server within {wait:?}")), } } @@ -130,7 +130,7 @@ impl TestPeer { match self.recv().await? { Message::Notification(n) => return Ok(n), Message::KeepAlive => {} - other => bail!("expected NOTIFICATION, got {other:?}"), + other => return Err(eyre::eyre!("expected NOTIFICATION, got {other:?}")), } } }