code: def ensure_started(self):
          
          if self.active:
              return self
          self._observer = self._observer_class(**self._observer_params)
          self.start()
          self._active = True
          return self
docs: Idempotent channel start