Create a new Subscription context manager.

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)