We are using NodeJS client to process events via catch-up subscriptions.
From documentation it looks like there are two ways of how to process data:
await for- an
oncallback
By applying domain knowledge I can process some of the events in parallel which I would apply here to improve the performance.
I ended up with some crazy logic in on callback method to pretty much put events back into sequence for processing.
Is there a way how to simply get a collection of events as batches as those are received from EventStore DB and apply the custom logic on them?