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
fat-arrow
known-types
hilla
videosdk.live
material-dialog
customscrollview
mdx-query
plex
progress-db
map-function
igrouping
surround
postdata
podman-compose
fetch-metadata
react-bootstrap4-modal
jacoco-maven-plugin
graphql-python
tinkerpop
reportbuilder3.0
karnaugh-map
styled-jsx
scrapy-request
tizen-certificate
wear-os-tiles
tomee-8
dom-events
yellow
ellipsize
affiliate