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
coded-ui-tests
flatten-pdf
esx
fqdn
isset
pixel-shading
use-case
column-major-order
spring-cloud-config
microstack
expanduser
cascade-notation
power-platform
maven-embedder
android-pageradapter
sortedlist
sparql-generate
sharpgl
react-refresh
urllib2
typeclass
nodatime
dynamicquery
elastica
buildconfig
rjdbc
httpentity
data-tier-applications
azure-cosmosdb-mongoapi
ctre