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
apache-ftpserver
performancecounter
android-blur-effect
asp.net-web-api2
server-communication
cloudflare-argo
imgur
odbcdatareader
name-value
transcription
qpixmap
pymongo-3.x
mkmapview
xsb
xmllint
jcodemodel
suitescript2.0
left-join
go-chi
terminal-server
speechsynthesizer
android-networking
parameter-passing
sync
zend-route
maven-frontend-plugin
ubsan
typescript1.6
runtypes
claims-authentication