code: def subscribe(self, subscription_channel, **observer_params):
          
          return self.get_channel(subscription_channel, **observer_params).ensure_started().observer
docs: Subscribe to a channel
  
          This adds a channel to the router, configures it, starts it, and returns its observer