user,
e.getResponseBodyAsString(Charset.defaultCharset()));
})
+ .takeUntil(message -> !running)
+ .doOnComplete(() -> log.info("TestWriter {} is done", user))
.parallel()
.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;