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-vts
rewind
office-dialog-api
allowed-origin
mappath
vfork
bearer-token
documentum
o-d-matrix
mission-control
wildfly-maven-plugin
uicollisionbehavior
abcpdf9
database-security
qradiobutton
orientation-changes
hexagonal-architecture
primes
absolute-value
turbo-pascal
geom-tile
avplayer
require-method
litecoin
cartopy
dotween
endpointnotfoundexception
cookieconsent
gitlab-ci
marvin-framework