src/Rxnet/RabbitMq/RabbitQueue.php
public function get($queue, $noAck = false)
    {
        $promise = $this->channel->get($queue, $noAck);
        return \Rxnet\fromPromise($promise)
            ->map(function (Message $message) {
                return new RabbitMessage($this->channel, $message, $this->serializer);
            });
    }
public function get($queue, $noAck = false)
    {
        $promise = $this->channel->get($queue, $noAck);
        return \Rxnet\fromPromise($promise)
            ->map(function (Message $message) {
                return new RabbitMessage($this->channel, $message, $this->serializer);
            });
    }
public function get ( $ queue , $ noAck = false ) { $ promise = $ this -> channel -> get ( $ queue , $ noAck ) ; return \ Rxnet \ fromPromise ( $ promise ) -> map ( function ( Message $ message ) { return new RabbitMessage ( $ this -> channel , $ message , $ this -> serializer ) ; } ) ; }
Pop one element from the queue
@param $queue
@param bool $noAck
@return Observable
Pop one element from the queue