return i++;
}
})
+ .delayElements(Duration.ofMillis(ThreadLocalRandom.current().nextLong(500, 1500)))
.map(i -> "Message #" + i)
- .flatMap(message -> Mono
- .delay(Duration.ofMillis(ThreadLocalRandom.current().nextLong(500, 1500)))
- .thenMany(sendMessage(chatRoom, message).retryWhen(Retry.fixedDelay(10, Duration.ofSeconds(1)))))
+ .flatMap(message -> sendMessage(chatRoom, message)
+ .retryWhen(Retry.fixedDelay(10, Duration.ofSeconds(1))))
.doOnNext(message ->
{
sentMessages.add(message);
private final WebClient webClient;
- private final ChatRoomInfoTo chatRoom;
+ final ChatRoomInfoTo chatRoom;
final User user;
final List<MessageTo> sentMessages = new LinkedList<>();