| 849 | static constexpr void submit(::io_uring_sqe&) noexcept {} |
| 850 | |
| 851 | void complete(::io_uring_cqe const & __cqe) noexcept |
| 852 | { |
| 853 | auto token = STDEXEC::get_stop_token(STDEXEC::get_env(__rcvr_)); |
| 854 | if (__cqe.res == -ECANCELED || __context_.stop_requested() || token.stop_requested()) |
| 855 | { |
| 856 | STDEXEC::set_stopped(static_cast<_Receiver&&>(__rcvr_)); |
| 857 | } |
| 858 | else |
| 859 | { |
| 860 | STDEXEC::set_value(static_cast<_Receiver&&>(__rcvr_)); |
| 861 | } |
| 862 | } |
| 863 | |
| 864 | __context& __context_; |
| 865 | STDEXEC_ATTRIBUTE(no_unique_address) _Receiver __rcvr_; |
nothing calls this directly
no test coverage detected