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
android-vpn-service
importerror
auto-responder
monad-transformers
rate-limiting
pybluez
netsh
cloudcaptain
aptitude
equal-range
sql-domain
microsoft-test-manager
motorcortex
emqx
tomography-reconstruction
transcrypt
ansible-handlers
android-clipboardmanager
apparition
befunge
interior-mutability
aws-media-convert
google-app-engine-python
setfocus
pylons
android-service
phpjs
fluid-framework
reparsepoint
index-sequence
