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
graphql-compose
pre-commit.com
openvas
kentico-kontent
master-slave
mvvm-light
resteasy
kedro
u-boot
youtube-analytics
refined
ibm-jdk
wxmaxima
spn
microsoft.data.sqlite
textmatching
amasty
slidingpanelayout
isin
dhcp
haskell-language-server
gitx
test-results
dcg
django-cms
ag-grid-column
modelandview
spanning-tree
waffle
pci-e