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
hmacsha1
sign-extension
shellcheck
audit
sap-hr
ilasm
appstore-approval
adminer
scngeometry
tabris
findbugs
laravel-3
mat-dialog
ntlmv2
activity-indicator
django-import-export
ui-testing
quotation-marks
kie-server
jumphost
structuremap
reader-monad
xamarin-studio
superpermutation
comet
traminer
wsl-2
posting
bulk-collect
finatra