projects / demos / kafka / chat / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: 099e03f) | 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>
Sun, 3 Mar 2024 10:44:42 +0000 (11:44 +0100)
commit1d7eef985c801d0a0fbb9b60cb7015b4e559aed9
tree99067b8311061a77dbefae6722a00c72ac6a8ff6tree | snapshot
parent099e03f7805f3c05b94be4e5d074bfb2c47943cecommit | 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.