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
series
qnx
npm-registry
instapaper
ltac
mapserver
mapview
github-search
visual-c++-runtime
jwebassembly
pygsheets
examplematcher
bilstm
text-size
camunda-modeler
developer-tools
google-analytics-userid
shellexecuteex
unordered
soa
three-way-merge
change-detector-ref
theory
dtn
haar-wavelet
dexguard
node-fetch
mailinabox
sts-securitytokenservice
kornia