2727
2828namespace beman ::execution::detail {
2929inline constexpr struct stop_when_t {
30-
3130 template <::beman::execution::sender Sndr, ::beman::execution::stoppable_token Tok>
3231 struct sender ;
3332
@@ -102,12 +101,12 @@ struct beman::execution::detail::stop_when_t::sender {
102101 state (S&& s, T&& t, R&& r)
103102 : tok(::std::forward<T>(t)),
104103 base{::std::forward<R>(r)},
105- inner_state (::beman::execution::connect(::std::forward<S>(s), receiver( &this ->base) )) {}
104+ inner_state (::beman::execution::connect(::std::forward<S>(s), receiver{ &this ->base } )) {}
106105
107106 auto start () & noexcept {
108- this ->cb1 .emplace (this ->tok , cb_t ( this ->base .source ) );
107+ this ->cb1 .emplace (this ->tok , cb_t { this ->base .source } );
109108 this ->cb2 .emplace (::beman::execution::get_stop_token (::beman::execution::get_env (this ->base .rcvr )),
110- cb_t ( this ->base .source ) );
109+ cb_t { this ->base .source } );
111110 ::beman::execution::start (this ->inner_state);
112111 }
113112 };
@@ -127,7 +126,7 @@ inline auto beman::execution::detail::stop_when_t::operator()(Sndr&& sndr, Tok&&
127126 if constexpr (::beman::execution::unstoppable_token<Tok>) {
128127 return ::std::forward<Sndr>(sndr);
129128 } else {
130- return sender<Sndr, Tok>( *this , ::std::forward<Tok>(tok), ::std::forward<Sndr>(sndr)) ;
129+ return sender<Sndr, Tok>{ *this , ::std::forward<Tok>(tok), ::std::forward<Sndr>(sndr)} ;
131130 }
132131}
133132
0 commit comments