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
terraform-provider-cloudflare
azure-logic-apps
first-order-logic
rust-goblin
deferred-execution
sabredav
data-sharing
log4j-1.2-cve
decal
geomesa
android-jetpack-compose-modifier
delta-sharing
videodisplay
spring-cloud-contract
vimspector
grep-indesign
jboss-tools
instar
django-formtools
glibc
printdialog
aem-project-archetype
ebean
identity-column
shared-element-transition
x-accel-redirect
pdf417
numberformatexception
maildir
youtube-player-flutter