We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 0889c17 commit c2828faCopy full SHA for c2828fa
server/src/main/java/com/hedera/block/server/consumer/ConsumerBlockItemObserver.java
@@ -71,10 +71,10 @@ public ConsumerBlockItemObserver(
71
((ServerCallStreamObserver<SubscribeStreamResponse>) subscribeStreamResponseObserver)
72
.setOnCancelHandler(
73
() -> {
74
+ streamMediator.unsubscribe(this);
75
LOGGER.log(
76
System.Logger.Level.DEBUG,
- "Consumer cancelled stream. Unsubscribing observer.");
77
- streamMediator.unsubscribe(this);
+ "Consumer cancelled stream. Observer unsubscribed.");
78
});
79
}
80
0 commit comments