fix: added additional call to test

Signed-off-by: Matt Peterson <[email protected]>
hashgraph · Sep 10, 2024 · 070f3da · 070f3da
1 parent c9f1d26
commit 070f3da
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/server/src/test/java/com/hedera/block/server/mediator/LiveStreamMediatorImplTest.java b/server/src/test/java/com/hedera/block/server/mediator/LiveStreamMediatorImplTest.java
@@ -444,6 +444,9 @@ public void testMediatorBlocksPublishAfterException() throws IOException {
         // Confirm the error counter was incremented
         assertEquals(1, blockNodeContext.metricsService().get(LiveBlockStreamMediatorError).get());
 
+        // Send another block item after the exception
+        streamMediator.publish(blockItems.get(1));
+
         final var subscribeStreamResponse =
                 SubscribeStreamResponse.newBuilder().blockItem(firstBlockItem).build();
         verify(streamObserver1, timeout(testTimeout).times(1))