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
pickup
dumpdata
hasura-cli
thunderbird-webextensions
cadvisor
recorder
coordinate
foswiki
class-decorator
tx-news
testcase
clever-cloud
hakyll
sonar-plugin
oracle12c
hotkeys
gspread
general-sql-parser
telegram-bot
skypedeveloper
passthrough-elements
createtextnode
yubico
libcurl
multi-database-connections
dbaas
data-security
powerdns
application-design
cornerstonejs