public function get($queue, $noAck = false): Observable
    {
        $promise = $this->channel->get($queue, $noAck);

        return Observable::fromPromise($promise)
            ->map(function (BaseMessage $message) {
                return new Message($this->channel, $message);
            });
    }
public function get($queue, $noAck = false): Observable
    {
        $promise = $this->channel->get($queue, $noAck);

        return Observable::fromPromise($promise)
            ->map(function (BaseMessage $message) {
                return new Message($this->channel, $message);
            });
    }
public function get ( $ queue , $ noAck = false ) : Observable { $ promise = $ this -> channel -> get ( $ queue , $ noAck ) ; return Observable :: fromPromise ( $ promise ) -> map ( function ( BaseMessage $ message ) { return new Message ( $ this -> channel , $ message ) ; } ) ; }
Pop one element from the queue.
Pop one element from the queue .