public function wait($quantity = 0)
    {
        $count = 0;
        $info  = stream_get_meta_data($this->streamSocket);
        while (is_resource($this->streamSocket) === true && feof($this->streamSocket) === false && empty($info['timed_out']) === true) {
            $line = $this->receive();

            if ($line === false) {
                return null;
            }

            if (strpos($line, 'PING') === 0) {
                $this->handlePING();
            }

            if (strpos($line, 'MSG') === 0) {
                $count++;
                $this->handleMSG($line);
                if (($quantity !== 0) && ($count >= $quantity)) {
                    return $this;
                }
            }

            $info = stream_get_meta_data($this->streamSocket);
        }

        $this->close();

        return $this;
    }
public function wait($quantity = 0)
    {
        $count = 0;
        $info  = stream_get_meta_data($this->streamSocket);
        while (is_resource($this->streamSocket) === true && feof($this->streamSocket) === false && empty($info['timed_out']) === true) {
            $line = $this->receive();

            if ($line === false) {
                return null;
            }

            if (strpos($line, 'PING') === 0) {
                $this->handlePING();
            }

            if (strpos($line, 'MSG') === 0) {
                $count++;
                $this->handleMSG($line);
                if (($quantity !== 0) && ($count >= $quantity)) {
                    return $this;
                }
            }

            $info = stream_get_meta_data($this->streamSocket);
        }

        $this->close();

        return $this;
    }
public function wait ( $ quantity = 0 ) { $ count = 0 ; $ info = stream_get_meta_data ( $ this -> streamSocket ) ; while ( is_resource ( $ this -> streamSocket ) === true && feof ( $ this -> streamSocket ) === false && empty ( $ info [ 'timed_out' ] ) === true ) { $ line = $ this -> receive ( ) ; if ( $ line === false ) { return null ; } if ( strpos ( $ line , 'PING' ) === 0 ) { $ this -> handlePING ( ) ; } if ( strpos ( $ line , 'MSG' ) === 0 ) { $ count ++ ; $ this -> handleMSG ( $ line ) ; if ( ( $ quantity !== 0 ) && ( $ count >= $ quantity ) ) { return $ this ; } } $ info = stream_get_meta_data ( $ this -> streamSocket ) ; } $ this -> close ( ) ; return $ this ; }
Waits for messages.

@param integer $quantity Number of messages to wait for.

@return Connection $connection Connection object
Waits for messages .