credo-ts icon indicating copy to clipboard operation
credo-ts copied to clipboard

fix: add concurrency config for processing message concurrently

Open Zzocker opened this issue 2 years ago • 8 comments

concatMap pipe processes messages synchronously, this PR adds the concurrency config and replaces concatMap with mergeMap to allow messages to be processed concurrently. Now that multi-tenant is supported, it will be helpful to process multiple messages at a time.

Signed-off-by: Pritam Singh [email protected]

Zzocker avatar Feb 09 '23 07:02 Zzocker