original_string: public function subscribe(Subscription $subscription)
      {
          if (!$this->isConnected) {
              return new RejectedPromise(new \LogicException('The client is not connected.'));
          }
  
          return $this->startFlow(new OutgoingSubscribeFlow([$subscription], $this->identifierGenerator));
      }
code: public function subscribe(Subscription $subscription)
      {
          if (!$this->isConnected) {
              return new RejectedPromise(new \LogicException('The client is not connected.'));
          }
  
          return $this->startFlow(new OutgoingSubscribeFlow([$subscription], $this->identifierGenerator));
      }
code_tokens: public function subscribe ( Subscription $ subscription ) { if ( ! $ this -> isConnected ) { return new RejectedPromise ( new \ LogicException ( 'The client is not connected.' ) ) ; } return $ this -> startFlow ( new OutgoingSubscribeFlow ( [ $ subscription ] , $ this -> identifierGenerator ) ) ; }
docstring: Subscribes to a topic filter.
  
  @param Subscription $subscription
  
  @return ExtendedPromiseInterface
docstring_tokens: Subscribes to a topic filter .