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
node-canvas
peekmessage
fingerprintjs
avd
angular-meteor
elixirls
pact-node
promisekit
date-formatting
odf
bangla-font
steamvr
transparency
commandparameter
streams-api
visa-api
elasticsearch-client
blazegraph
upnpx
nsmutableparagraphstyle
public-key
jenkins-pipeline
aforge
azure-databricks
whatwg-streams-api
pgbackrest
googlemobileads
church-encoding
actions-on-google
file-length