From ca33b8bbfa26ed8e15c386c5ed6452244ccd0eb4 Mon Sep 17 00:00:00 2001 From: Marcel Moura Date: Thu, 14 Sep 2023 18:24:46 -0300 Subject: [PATCH] fixup! feat(offchain): implement the broker-listener for the authority-claimer --- offchain/rollups-events/tests/integration.rs | 12 ------------ 1 file changed, 12 deletions(-) diff --git a/offchain/rollups-events/tests/integration.rs b/offchain/rollups-events/tests/integration.rs index 316ef188a..6bfaa9cc8 100644 --- a/offchain/rollups-events/tests/integration.rs +++ b/offchain/rollups-events/tests/integration.rs @@ -286,15 +286,3 @@ async fn test_it_does_not_block_when_consuming_empty_stream() { .expect("failed to peek"); assert!(matches!(event, None)); } - -#[test_log::test(tokio::test)] -async fn test_it_times_out_when_no_event_is_produced() { - let docker = Cli::default(); - let state = TestState::setup(&docker).await; - let mut broker = state.create_broker().await; - let err = broker - .consume_blocking(&MockStream {}, "0") - .await - .expect_err("consume event worked but it should have failed"); - assert!(matches!(err, BrokerError::ConsumeTimeout)); -}