Using the Java Flow API. I have a chain of Processors and a terminal Subscriber. I have coded up Subscribers that have kept a count of items received that work
riak
activemq-cpp
elasticsearch-painless">elasticsearch-painless
strassen
upn
low-latency
android-enterprise-features
name-decoration
step-into
dynamic-dispatch
appauthhelper
musicbrainz
aws-pinpoint
openweathermap
code128
bazel-cpp
terra-blockchain
cpu
java-18
handlerinterceptor
archunit
qimagereader
mongo-collection
data-hiding
amazon-gamelift
dwm
tiki-wiki
objective-c-2.0
screen-off
mysql-dependent-subquery