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
telephony
architect
boost-polygon
interaction-plot
acumatica
ipython-sql
google-schemas
compress-archive
wampserver
locationmatch
mapbox-api-directions
daemon
rfc1034identifier
clickable-image
waitgroup
rackup
intel
fedora-25
cloud-security
ruby-on-rails-3.1
elasticsearch-dsl-py">elasticsearch-dsl-py
multi-table
single-spa-react
gcp-alerts
buildsrc
greedy
nexe
tetris
groupingby
xcode4.3