code: def start_subscribe(self):
          
          if not self.conn:
              raise ValueError('Not connected')
          elif not self.pubsub_conn:
              raise ValueError('PubSub not enabled')
  
          # creates a new context manager
          return Subscription(self)
docs: Create a new Subscription context manager.