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
soapcore
paragraph-marker
new-expression
red-gate-sql-prompt
bodybuilder.js
posthtml
react-native-animatable
asp.net-caching
gracenote
velocity
time-t
oidc-client-js
ptrace
webserver
android-webview
ktor-client
azure-managed-app
network-monitoring
grid-layout
visual-composer
jquery-lazyload
multiscaleimage
ctcallcenter
groq
page-replacement
scalar-subquery
cross-domain-policy
cabal-new
datarobot
page-refresh