Skip to content

Commit d7c9709

Browse files
committed
try to fix the libdispatch bulk sender
1 parent ce46fb6 commit d7c9709

File tree

1 file changed

+10
-9
lines changed

1 file changed

+10
-9
lines changed

include/exec/libdispatch_queue.hpp

Lines changed: 10 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -280,22 +280,23 @@ namespace exec {
280280

281281
template <stdexec::__decays_to<__t> Self, stdexec::receiver Receiver>
282282
requires stdexec::receiver_of<Receiver, __completions_t<Self, stdexec::env_of_t<Receiver>>>
283-
static bulk_op_state_t<Self, Receiver>
284-
connect(Self &&self, Receiver rcvr) noexcept(stdexec::__nothrow_constructible_from<
285-
bulk_op_state_t<Self, Receiver>,
286-
libdispatch_queue &,
287-
Shape,
288-
Fun,
289-
Sender,
290-
Receiver
291-
>) {
283+
STDEXEC_EXPLICIT_THIS_BEGIN(auto connect)(this Self &&self, Receiver rcvr)
284+
noexcept(stdexec::__nothrow_constructible_from<
285+
bulk_op_state_t<Self, Receiver>,
286+
libdispatch_queue &,
287+
Shape,
288+
Fun,
289+
Sender,
290+
Receiver
291+
>) -> bulk_op_state_t<Self, Receiver> {
292292
return bulk_op_state_t<Self, Receiver>{
293293
self.queue_,
294294
self.shape_,
295295
self.fun_,
296296
(std::forward<Self>(self)).sndr_,
297297
(std::forward<Receiver>(rcvr))};
298298
}
299+
STDEXEC_EXPLICIT_THIS_BEGIN(connect)
299300

300301
template <stdexec::__decays_to<__t> Self, class... Env>
301302
STDEXEC_EXPLICIT_THIS_BEGIN(auto get_completion_signatures)(this Self &&, Env &&...)

0 commit comments

Comments
 (0)