]> juplo.de Git - demos/kafka/chat/commit
projects / demos / kafka / chat / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: d1df165) | patch
test: HandoverIT-POC - working fix: using `delayElements()`
authorKai Moritz <kai@juplo.de>
Sun, 3 Mar 2024 09:08:36 +0000 (10:08 +0100)
committerKai Moritz <kai@juplo.de>
Thu, 14 Mar 2024 08:11:21 +0000 (09:11 +0100)
commit0ec944bf136815949f3740c94ec8fb8ca8c9d629
tree53621ad28fbfd1c34b0d3786e9ccef6e587597d7tree | snapshot
parentd1df165c12a9163ba012475dbdd30971794a3748commit | diff
test: HandoverIT-POC - working fix: using `delayElements()`

* Switched from `Flux.flatMap(Mono.delay()..)` to
  `Flux.from(..).delayElements()`FIX:delay_vs_delayElements.
* This delays eache element of the `Flux` by the same amount.
* The requests are made, when the according element of the flux is
  executed - not when the `Flux` is created, as before.
src/test/java/de/juplo/kafka/chat/backend/TestWriter.java diff | blob | history
Unnamed repository; edit this file 'description' to name the repository.