projects / demos / kafka / chat / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: 7c085ad) | patch
test: HandoverIT-POC - FIX: `TestWriter` must use `Flux#concatMap()`
authorKai Moritz <kai@juplo.de>
Fri, 15 Mar 2024 15:10:31 +0000 (16:10 +0100)
committerKai Moritz <kai@juplo.de>
Fri, 22 Mar 2024 16:39:20 +0000 (17:39 +0100)
commit1af73fed7db47bbc624c0004f140597a48149bed
treea94456ebba324eefdc8cf0564864f3cd60876fcbtree | snapshot
parent7c085ad58c3b99a48de8b88d9c251f21531c72e0commit | diff
test: HandoverIT-POC - FIX: `TestWriter` must use `Flux#concatMap()`

* `Flux#flatMap()` executes in parallel. Hence, the enqueued messages
  are _not_ send in the order, that they were enqueued.
* Therefore, the `TestWriter` was refactored to use `Flux#concatMap()`,
  which executes serially.
src/test/java/de/juplo/kafka/chat/backend/TestWriter.java diff | blob | history
Unnamed repository; edit this file 'description' to name the repository.