projects / demos / kafka / chat / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: 1a54d7a) | 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>
Sun, 3 Mar 2024 10:49:09 +0000 (11:49 +0100)
commit78cda5eb4761c62f5de1a84a68698bd01e607bdb
tree53621ad28fbfd1c34b0d3786e9ccef6e587597d7tree | snapshot
parent1a54d7ae28cff0e973f3bb9ba6ed35706f340a8ecommit | 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.