Method start

include/exec/when_any.hpp:203–215

      STDEXEC_IMMOVABLE(__opstate);

      void start() & noexcept
      {
        this->__on_stop_.emplace(get_stop_token(get_env(this->__rcvr_)),
                                 __forward_stop_request{this->__stop_source_});
        if (this->__stop_source_.stop_requested())
        {
          STDEXEC::set_stopped(static_cast<_Receiver&&>(this->__rcvr_));
        }
        else
        {
          STDEXEC::__apply(STDEXEC::__for_each{STDEXEC::start}, __ops_);
        }
      }

     private:
      __opstates_t __ops_;