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
android-gridlayout
stamps.com
fbdev
semantic-ui-css
js-of-ocaml
design-time
hole-punching
android-location
python-dragonfly
boost-multi-array
mappedby
td-agent
gemfile.lock
biplot
matplotlib-animation
react-native-navigation
qtableview
waffle-chart
splunk-calculation
shell
ef-core-2.2
astrojs
dask-jobqueue
clip-path
clickjacking
quickform
data-munging
google-datastream
static-cast
object-oriented-analysis