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
symfony-components
quarkus-oidc
add
class-completion
code-generation
testcaseattribute
oracle-rest-data-services
angularjs-compile
katana
nodelist
meteor-blaze
protobuf-net.grpc
ijkplayer
sdl
procedural-generation
sharepoint-apps
c2664
custom-errors
jbullet
frame
nvm
spray
tapestry
gherkin
actualheight
configurable-product
vision
wm-copydata
oci-terraform
visualbrush