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
tycho-surefire-plugin
wildfly
bootstrap-rtl
installshield-2016
parental-control
discriminator
bizcharts
eigenvalue
postgresql-8.0
ts-jest
srecord
datetime64
dot-source
pkcs#1
queue-federation
mobx-persist
iorderedqueryable
bootstrap-treeview
binary-reproducibility
cm-synergy
powermail
tsconfig-paths
reactive
cancan
hardware
php-opencloud
private-ip
neo4j-graphql-js
f-bounded-polymorphism
cobol