Hello. Is there an event that shows exactly that producer is ready for consume? I need it because almost a second after transport.observer.on('newproducer' ...) (or await transport.produce ) router.canConsume with the producer id still return false. It returns true only some milliseconds after.
That must be an error in your code. To be perfectly clear: it works fine.
Is it same for await router.pipeToRouter ?
Yes, it’s.