user,
e.getResponseBodyAsString(Charset.defaultCharset()));
})
- .parallel()
+ .limitRate(1)
+ .takeUntil(message -> !running)
+ .doOnComplete(() -> log.info("TestWriter {} is done", user))
+ .parallel(1)
.runOn(Schedulers.parallel())
.then();
}
private final WebClient webClient;
private final ChatRoomInfoTo chatRoom;
- private final User user;
+ final User user;
final List<MessageTo> sentMessages = new LinkedList<>();
volatile boolean running = true;