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
pod-install
centralized
entity-framework-core-3.1
duplicate-data
graceful-degradation
url-masking
cancellationtokensource
rdl
ilog
mujoco
bionic
xdebug
react-native-shared-element
caesar-cipher
border-box
creation-timestamp
executionpolicy
asp.net-core-mvc
flutter-form-builder
array-algorithms
kendo-treelist
cortex-m
laminas
django-datatable
numpy-dtype
kubeflow
imputation
zipper
forward-list
rowdatabound
