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
ivy
magnitude
command-line
chrome-profile
cssnext
fire-and-forget
karate
bea
qtremoteobjects
testng
dask-kubernetes
jbpm
flutter-get
highlightjs
general-log
newtype
python-holidays
quad
undirected-graph
enable-if
mat-form-field
swift-playground
web-content
tikz
j2html
bodymovin
flutter-slider
create-react-kotlin-app
direct-rendering-manager
filesaver.js