public function unsubscribe(Subscription $subscription)
    {
        if (!$this->isConnected) {
            return new RejectedPromise(new \LogicException('The client is not connected.'));
        }

        return $this->startFlow(new OutgoingUnsubscribeFlow([$subscription], $this->identifierGenerator));
    }
public function unsubscribe(Subscription $subscription)
    {
        if (!$this->isConnected) {
            return new RejectedPromise(new \LogicException('The client is not connected.'));
        }

        return $this->startFlow(new OutgoingUnsubscribeFlow([$subscription], $this->identifierGenerator));
    }
public function unsubscribe ( Subscription $ subscription ) { if ( ! $ this -> isConnected ) { return new RejectedPromise ( new \ LogicException ( 'The client is not connected.' ) ) ; } return $ this -> startFlow ( new OutgoingUnsubscribeFlow ( [ $ subscription ] , $ this -> identifierGenerator ) ) ; }
Unsubscribes from a topic filter.

@param Subscription $subscription

@return ExtendedPromiseInterface
Unsubscribes from a topic filter .