Branislav Katreniak

Results 2 issues of Branislav Katreniak

Steps to reproduce the problem: * configure consumer with `setDefaultConsumeTimeout(1000)` * produce 1 message every 500ms * call `consumer.consume(128, cb)` Actual outcome: * consume returns batch of 128 messages after...

…ection Add an asyncLocalStorage plugin option to allow injecting an external AsyncLocalStorage instance. This enables sharing a single AsyncLocalStorage across multiple request sources in applications that handle requests from various...