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
clearance
esx
system.io.pipelines
nrepl
multi-catch
ssjs
usermetadata
npm-start
rowversion
woodpecker-ci
tooltip
scraperwiki
webservicehost
jackrabbit
zend-framework3
django-timezone
logrank-test
zypper
openfiledialog
ascii-art
xlpagertabstrip
floating-ip
clear-cache
monodevelop
azure-app-permissions
oxygenxml
frameset
shapedrawable
wxnotebook
ethercat