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
netbeans-7
qtserial
mathematica-8
compound-query
stretchdibits
group-membership
event-flow
prisma-graphql
swtpm
webshot
android-event
sqlite-net-pcl
click-through
angular-hybrid
django-context
excel-r1c1-notation
schedule
openwebbeans
adaptive-user-interfaces
shared-data
remote-notifications
angular-config
libsox
associations
diamond-operator
django-request
stormcrawler
setforegroundwindow
copywithzone
grpc-kotlin