Closed
Description
Please propagate DuplexStreamInterface::on('data')
as normal event not just a promise.
Promises are only fit when you need to do a single call.
When you need a BLPOP
/XREAD
/XREADGROUP
-based endless reading loop, event is a must have.
I think you can use command name as an event name so user will be able to choose what to handle.