original_string: public function consume($queue, $prefetchCount = null, $prefetchSize = null, $consumerId = null): Observable
      {
          return $this->channel()
              ->do(function (Channel $channel) use ($prefetchCount, $prefetchSize) {
                  $channel->qos($prefetchSize, $prefetchCount);
              })
              ->flatMap(
                  function (Channel $channel) use ($queue, $consumerId) {
                      return $this->queue($queue, $channel)
                          ->consume($consumerId);
                  }
              );
      }
code: public function consume($queue, $prefetchCount = null, $prefetchSize = null, $consumerId = null): Observable
      {
          return $this->channel()
              ->do(function (Channel $channel) use ($prefetchCount, $prefetchSize) {
                  $channel->qos($prefetchSize, $prefetchCount);
              })
              ->flatMap(
                  function (Channel $channel) use ($queue, $consumerId) {
                      return $this->queue($queue, $channel)
                          ->consume($consumerId);
                  }
              );
      }
code_tokens: public function consume ( $ queue , $ prefetchCount = null , $ prefetchSize = null , $ consumerId = null ) : Observable { return $ this -> channel ( ) -> do ( function ( Channel $ channel ) use ( $ prefetchCount , $ prefetchSize ) { $ channel -> qos ( $ prefetchSize , $ prefetchCount ) ; } ) -> flatMap ( function ( Channel $ channel ) use ( $ queue , $ consumerId ) { return $ this -> queue ( $ queue , $ channel ) -> consume ( $ consumerId ) ; } ) ; }
docstring: Consume given queue at.
docstring_tokens: Consume given queue at .