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
dialplan
webpack-remove-empty-scripts
neon
nativescript-cli
virtual-functions
microsoft-extensions-logging
svelte-component
minimized
discriminator
simpletransformers
dxcore
firebird2.1
recursive-cte
liquid-template
file-upload
glob
optimistic-locking
qtsql
asp.net-mvc-partialview
module-info
playing-cards
glr
java-flow
lazy-loading
gsap
cwp
fbsdkloginkit
template-instantiation
spinbox
ghci