function close() {
        if($this->closed) {
            return;
        }
        
        $this->closed = true;
        if($this->started && $this->paused) {
            $this->driver->resumeStreamConsumption();
        }
        
        $this->emit('close');
        $this->removeAllListeners();
    }
function close() {
        if($this->closed) {
            return;
        }
        
        $this->closed = true;
        if($this->started && $this->paused) {
            $this->driver->resumeStreamConsumption();
        }
        
        $this->emit('close');
        $this->removeAllListeners();
    }
function close ( ) { if ( $ this -> closed ) { return ; } $ this -> closed = true ; if ( $ this -> started && $ this -> paused ) { $ this -> driver -> resumeStreamConsumption ( ) ; } $ this -> emit ( 'close' ) ; $ this -> removeAllListeners ( ) ; }
Closes the stream. Resumes the connection stream.
@return void
Closes the stream . Resumes the connection stream .