credo-ts
credo-ts copied to clipboard
fix: add concurrency config for processing message concurrently
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]