docs: def start_subscribe(self):
          """Create a new Subscription context manager."""
          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)