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
numerical-methods
databricks-repos
monaca
fsm
react-gql
android-attributes
sklightnode
flash-media-server
hyperas
roulette-wheel-selection
react-devtools
nvidia
swagger-2.0
cg
browser-automation
next-i18next
asp.net-boilerplate
django-paypal
nsurlsession
fivetran
control-characters
roottools
vue-chartjs
apache-aries
elasticsearch-bulk">elasticsearch-bulk
android-studio-arctic-fox
scrolltorow
ib-insync
travis-ci
vpc