oxidmod

already done, but problem exist

Thanks to @adam-lmi for pointing on my mistake with "No handler for message xxxx"

How about code like this? There is no need to create new closure every time ``` class TestConsumer { private Closure $handler; public function __construct(private array $messageHandlers) { $this->handler =...

@nekufa Yeap. I'll do it ASAP

@nekufa looks like it isn't so easy. For correct disconnect we also have to implement drain process. It will take more time that I thought previously. I'll do it but...

> @oxidmod never mind, it's not a problem for me. if you need any help in implementation, feel free to contact me http://t.me/nekufa Thanks