src/Client.php
public function close(): void
    {
        if ($this->isClosed) {
            return;
        }

        $this->isEnding = true;
        $this->isClosed = true;

        $this->connection->close();
        $this->emit('close');

        $this->pool->rejectAll(new ConnectionClosedException());
    }
public function close(): void
    {
        if ($this->isClosed) {
            return;
        }

        $this->isEnding = true;
        $this->isClosed = true;

        $this->connection->close();
        $this->emit('close');

        $this->pool->rejectAll(new ConnectionClosedException());
    }
public function close ( ) : void { if ( $ this -> isClosed ) { return ; } $ this -> isEnding = true ; $ this -> isClosed = true ; $ this -> connection -> close ( ) ; $ this -> emit ( 'close' ) ; $ this -> pool -> rejectAll ( new ConnectionClosedException ( ) ) ; }
Forces closing the connection and rejects all pending requests
Forces closing the connection and rejects all pending requests