| 649 | __on_stop>; |
| 650 | |
| 651 | void start() & noexcept |
| 652 | { |
| 653 | std::optional<__on_stopped_callback> __callback(std::in_place, |
| 654 | STDEXEC::get_stop_token( |
| 655 | STDEXEC::get_env(__rcvr_)), |
| 656 | __on_stop{__context_}); |
| 657 | STDEXEC_TRY |
| 658 | { |
| 659 | if (__mode_ == until::stopped) |
| 660 | { |
| 661 | __context_.run_until_stopped(); |
| 662 | } |
| 663 | else |
| 664 | { |
| 665 | __context_.run_until_empty(); |
| 666 | } |
| 667 | } |
| 668 | STDEXEC_CATCH_ALL |
| 669 | { |
| 670 | __callback.reset(); |
| 671 | STDEXEC::set_error(static_cast<_Rcvr&&>(__rcvr_), std::current_exception()); |
| 672 | } |
| 673 | __callback.reset(); |
| 674 | if (__context_.stop_requested()) |
| 675 | { |
nothing calls this directly
no test coverage detected