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
amp-form
money-rails
drop-duplicates
addressbook
adt
workbench
sonarqube5.1.2
catia
jenkins-slave
aws-step-functions
vertica-python
drupal-content-types
equivalence
filecontentresult
compiler-options
nominatim
jvcl
lmplot
gluon-desktop
futuretask
instana
tortoise-orm
deb
fable-f#
dotnetzip
github-flavored-markdown">github-flavored-markdown
project-properties
carthage
xfdf
iterator