Phaser writtenChatRooms = new Phaser(1);
AtomicInteger numErrors = new AtomicInteger();
- writeChatRoomInfo(
+ Flux<ChatRoomInfo> chatRoomInfoFlux =
chatHomeService
.getChatRoomInfo()
.doOnNext(chatRoomInfo -> writtenChatRooms.register())
logFailure(chatRoomId, throwable);
numErrors.incrementAndGet();
writtenChatRooms.arriveAndDeregister();
- })));
+ }));
+
+ writeChatRoomInfo(chatRoomInfoFlux);
writtenChatRooms.arriveAndAwaitAdvance();
if (numErrors.get() > 0)