projects / demos / kafka / chat / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: 1d7eef9) | patch
test: HandoverIT-POC - not working fix: using `delay()`
authorKai Moritz <kai@juplo.de>
Sat, 2 Mar 2024 17:21:44 +0000 (18:21 +0100)
committerKai Moritz <kai@juplo.de>
Sun, 3 Mar 2024 10:46:29 +0000 (11:46 +0100)
commit1a54d7ae28cff0e973f3bb9ba6ed35706f340a8e
tree5887cbbfc95798860895acdcfa0828db32d50e84tree | snapshot
parent1d7eef985c801d0a0fbb9b60cb7015b4e559aed9commit | diff
test: HandoverIT-POC - not working fix: using `delay()`

* Switched from `Mono.from(..).delayElement()` to `Mono.delay().then()`.
* This does _not_ solve the problem, that all delays are calculated and
  scheduled, when the `Flux` is created.
src/test/java/de/juplo/kafka/chat/backend/TestWriter.java diff | blob | history
Unnamed repository; edit this file 'description' to name the repository.