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
ubuntu-14.10
jscript.net
kotlinx.coroutines.channels
kendo-mobile
bitvector
sample-rate
bookshelf.js
parallel-tests
vuejs-datepicker
samsung-galaxy-gear
kuzzle
statsplots
azure-webjobs-triggered
feed-forward
xpath-3.0
apollostack
bluetooth-mesh
arcgis-android-api
fann
topic-modeling
mxnet-gluon
terraform-provider-gcp
datetime-local
schannel
defaultmutabletreenode
http-status
return-code
decibel
celluloid
extended-choice-parameter