protected function bufferize($types = [])
    {
        while (true) {
            $this->buffer = $this->findNextMessages($types);

            if (\count($this->buffer) > 0) {
                break;
            }

            usleep($this->pause);
        }
    }
protected function bufferize($types = [])
    {
        while (true) {
            $this->buffer = $this->findNextMessages($types);

            if (\count($this->buffer) > 0) {
                break;
            }

            usleep($this->pause);
        }
    }
protected function bufferize ( $ types = [ ] ) { while ( true ) { $ this -> buffer = $ this -> findNextMessages ( $ types ) ; if ( \ count ( $ this -> buffer ) > 0 ) { break ; } usleep ( $ this -> pause ) ; } }
Fill the inner messages buffer.

@param array $types
Fill the inner messages buffer .