MCPcopy Create free account
hub / github.com/NVIDIA/stdexec / __run

Method __run

include/stdexec/__detail/__spawn_future.hpp:675–684  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

673 ~__future_operation() {}
674
675 void __run() noexcept(__stop_callback_is_nothrow_constructible<env_of_t<_Receiver>>)
676 {
677 // this might throw
678 std::construct_at(&__callback_,
679 STDEXEC::get_stop_token(STDEXEC::get_env(__rcvr_)),
680 __future_stop_callback{this->__future_.get()});
681
682 // this is no-throw
683 this->__future_.release()->__consume(__inner_rcvr_);
684 }
685
686 _Receiver __rcvr_;
687

Callers 1

__spawn_future_implClass · 0.45

Calls 4

__consumeMethod · 0.80
get_envFunction · 0.70
getMethod · 0.45
releaseMethod · 0.45

Tested by

no test coverage detected