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
vcpu
libpd
listviewitem
nsinputstream
watershed
callr
robotframework-ide
software-quality
delegated-properties
alglib
dynamic-programming
kaminari
extrafont
python-for-android
berkeley-db
alpha-vantage
nonce
jquery-ui-dialog
azure-secrets
nls
static-data
minima
akka.net-cluster
slide
stdset
win2d
observium
bot-emulator
kong
word-web-addins