* `take(n)` does end the execution.
* `limitRate(n)` limits the rate of requested elements.
"Received a message from chat-room {}: {}",
chatRoom.getName(),
message);
"Received a message from chat-room {}: {}",
chatRoom.getName(),
message);
.takeUntil(message -> !running)
.doOnComplete(() -> log.info("TestListener is done"))
.parallel(chatRooms.length)
.takeUntil(message -> !running)
.doOnComplete(() -> log.info("TestListener is done"))
.parallel(chatRooms.length)
user,
e.getResponseBodyAsString(Charset.defaultCharset()));
})
user,
e.getResponseBodyAsString(Charset.defaultCharset()));
})
.takeUntil(message -> !running)
.doOnComplete(() -> log.info("TestWriter {} is done", user))
.parallel(1)
.takeUntil(message -> !running)
.doOnComplete(() -> log.info("TestWriter {} is done", user))
.parallel(1)