ASync reader

[h-bragg]

Using someones implementation of an event loop and async streams, create an Asynchronous Client

removes the need for acknowledgement handler (a little bit)

interface AsyncMessageHandler {
    public function handle(MessageInterface $message, callable $done) : PromiseInterface
}

class Reader {
    public function asyncRead(AsyncMessageHandler $handler, int $num) {
        // read
        $handler->handle($message, $done)
                ->then($this->acknowledge, $this->reject);
    }
}

[h-bragg]

A start I made a while ago: https://github.com/graze/queue/tree/async-queues