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
hql
sp-rename
tstream
soapy-sdr
android-search
rfc2231
mobx-angular
opencv3.2
sonarqube-ops
application-server
commonschunkplugin
lnk2001
textualize
forestplot
web-frameworks
pyathena
carriage-return
android-savedstate
url-for
infinite-recursion
fragmentstatepageradapter
snowflake-cloud-data-platform
codemirror-6
check-constraints
exception-handling
polyml
azure-database-postgresql
smartgwt
react-native-notifications
eclim
