| 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 |
no test coverage detected