.fromArray(chatRooms)
.flatMap(chatRoom ->
{
+ log.info("Requesting messages from chat-room {}", chatRoom);
List<MessageTo> list = new LinkedList<>();
receivedMessages.put(chatRoom.getId(), list);
return receiveMessages(chatRoom)
list.add(message);
log.info(
"Received a message from chat-room {}: {}",
- chatRoom,
+ chatRoom.getName(),
message);
})
- .take(30);
+ .take(10);
})
+ .take(100)
.takeUntil(message -> !running)
- .parallel()
+ .doOnComplete(() -> log.info("TestListener is done"))
+ .parallel(chatRooms.length)
.runOn(Schedulers.parallel())
.then();
}