projects / demos / kafka / chat / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: bffdb31) | patch
test: HandoverIT-POC - FIX: `take(n)`, does end the work after n elements
authorKai Moritz <kai@juplo.de>
Sat, 2 Mar 2024 17:21:05 +0000 (18:21 +0100)
committerKai Moritz <kai@juplo.de>
Thu, 14 Mar 2024 08:11:21 +0000 (09:11 +0100)
commit7286776e39b3adcb3d8bff7e43d1b33305919ac2
tree99067b8311061a77dbefae6722a00c72ac6a8ff6tree | snapshot
parentbffdb31bcf964667075659be6a3015213e12de32commit | diff
test: HandoverIT-POC - FIX: `take(n)`, does end the work after n elements

* `take(n)` does end the execution.
* `limitRate(n)` limits the rate of requested elements.
src/test/java/de/juplo/kafka/chat/backend/TestListener.java diff | blob | history
src/test/java/de/juplo/kafka/chat/backend/TestWriter.java diff | blob | history
Unnamed repository; edit this file 'description' to name the repository.