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
.net-core-authorization
vertx-redis-client
soapcore
uisplitviewdelegate
statsmodels
pokemon-go
dataproc
plex
jslint
terraform-registry
cgal
azure-iot-sdk
finch
abac
skew
forced-unwind
hortonworks-sandbox
amazon-elastic-beanstalk">amazon-elastic-beanstalk
google-fit
jquery-migrate
conda-forge
ngsw-config
gridfs-stream
mouseup
swiftdate
mixpanel
base
keyerror
ax
assetic