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
dmo
elevation
greasemonkey-4
android-capture
windows-themes
edid
persistent-memory
oslo
nestjs-config
keyboard-avoidance
pytables
django-middleware
media-library
clap
short-circuiting
access-log
bulletphysics
string-agg
adonetappender
first-level-cache
parquet
qfilesystemmodel
identity-insert
rrd
antialiasing
in-call
trusted-vs-untrusted
firebird-4.0
kivy
hashchange