]> juplo.de Git - demos/kafka/chat/commit
projects / demos / kafka / chat / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: 78eb7b9) | 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>
Fri, 22 Mar 2024 16:37:42 +0000 (17:37 +0100)
commita512a8de7458d72d3b7e1beb96faa88fc308f1d0
tree5d0b3e14783697003f3f15a929bfa4e8e92dc8f1tree | snapshot
parent78eb7b92d802e684a49160933894c4f0d95b103bcommit | 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.