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
trojan
docassemble
event-arc
tfs-2019
django-cache
choice
graphql-dotnet
dataiku
wp-mail
dlclose
applicationmanager
idisposable
cgridview
fseek
onutterancecompleted
testbed
fileserver
expss
sigma-grid-control
simpleautocompletetextfield
fastify
option-type
http-status-code-200
code128
uibarbuttonsystemitem
pytorch-forecasting
watson-discovery
holoviz
yaml-front-matter
httpcontext