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
unicode-normalization
twitter-bootstrap-tooltip
cfinvoke
gpy
constraint-layout-chains
change-data-capture
asp.net-core-2.2
partitioning
aws-codestar
flowplayer
copy-and-swap
ionicons
react-portal
flask-marshmallow
google-finance-api
fifo
custom-model-binder
port80
module
category-theory
stringr
bookdown
for-loop
easyphp
jain-sip
uitabbaritem
xdt-transform
kmm
yesod
sublime-build