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
jboss-rules
django-custom-field
cypress-task
sspi
android-actionmode
fb.ui
ksh
aws-sdk
self-contained
icefaces
import-libraries
angular-dom-sanitizer
gradle-plugin
localauthentication
csharpscript
imagesource
uipath-api
ibm-cloud-storage
ios5
rmdformats
direct3d12
blitz.js
android-log
listmodel
cakephp-2.x
stackalloc
powerapps-selected-items
google-surveys
cmusphinx
parquet