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
ggalluvial
gnu-parallel
git-history-graph
ueye
react-native-firebase
visual-studio-setup
tablecolumn
rxjs-subscriptions
dynamic-pages
redislabs
aegis
gutter
mdm
bodybuilder.js
sentence-similarity
nodebb
bigdl
rocksdb
documentfile
nsindexset
unity-uss
adapter
bootstrap-wysiwyg
cs-cart
momentics
suitecommerce
pitch-detection
graphicsmagick
omnikey
nullable-reference-types