lib/DataSift/StreamConsumer.php
public function consume($auto_reconnect = true)
    {
        $this->_auto_reconnect = $auto_reconnect;

        // Start consuming
        $this->_state = self::STATE_STARTING;
        $this->onStart();
    }
public function consume($auto_reconnect = true)
    {
        $this->_auto_reconnect = $auto_reconnect;

        // Start consuming
        $this->_state = self::STATE_STARTING;
        $this->onStart();
    }
public function consume ( $ auto_reconnect = true ) { $ this -> _auto_reconnect = $ auto_reconnect ; // Start consuming $ this -> _state = self :: STATE_STARTING ; $ this -> onStart ( ) ; }
Once an instance of a StreamConsumer is ready for use, call this to
start consuming. Extending classes should implement onStart to handle
actually starting.

@param boolean $auto_reconnect Whether to reconnect automatically

@return void
Once an instance of a StreamConsumer is ready for use call this to start consuming . Extending classes should implement onStart to handle actually starting .