Skip to content

[WIP] Tail sender #678

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Draft
wants to merge 14 commits into
base: main
Choose a base branch
from
Draft

[WIP] Tail sender #678

Show file tree
Hide file tree
Changes from 1 commit
Commits
Show all changes
14 commits
Select commit Hold shift + click to select a range
a3f8c9b
tail_sender concepts
kirkshoop Oct 31, 2022
b1d4417
add __null_tail_sender
kirkshoop Oct 31, 2022
5699467
add maybe_tail_sender
kirkshoop Oct 31, 2022
374043d
start, set_value, set_error, and set_stopped may return a tail_sender
kirkshoop Nov 1, 2022
ca7e6f2
add __start_until_nullable
kirkshoop Nov 1, 2022
e80f3a6
add __start_sequential
kirkshoop Nov 2, 2022
6af616a
add variant_tail_sender
kirkshoop Nov 5, 2022
86b486a
add resume_tail_senders_until_one_remaining
kirkshoop Nov 5, 2022
c71ebd0
fixes post rebase
kirkshoop Dec 30, 2022
d05357c
adding some tests
kirkshoop Feb 6, 2023
236c959
Merge remote-tracking branch 'origin/main' into tail_sender
ericniebler Mar 22, 2023
715c973
apply clang-format
ericniebler Mar 22, 2023
26c387b
instruct git blame to skip the format commit
ericniebler Mar 22, 2023
d56bc34
naming
ericniebler Mar 22, 2023
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
fixes post rebase
  • Loading branch information
@kirkshoop
kirkshoop committed Feb 6, 2023
commit c71ebd0ba7d77ccfbe47479bbff40f0f0636a0b8
2 changes: 1 addition & 1 deletion include/exec/variant_tail_sender.hpp
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -207,7 +207,7 @@ namespace exec {
using __f =
__mapply<
_Continuation,
__minvoke<__fold_right<__types<>, __push_back_flatten<__q<__types>>>, _Ts...>>;
__minvoke<__mfold_right<__types<>, __push_back_flatten<__q<__types>>>, _Ts...>>;
};

template <class _Continuation>
Expand Down
8 changes: 4 additions & 4 deletions test/exec/test_tail_sender.cpp
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -63,8 +63,8 @@ struct ATailReceiver {
int* called;
friend void tag_invoke(ex::set_value_t, ATailReceiver&& __self, auto&&...) noexcept { ++*__self.called; }
friend void tag_invoke(ex::set_stopped_t, ATailReceiver&& __self) noexcept { ++*__self.called; }
friend ex::__debug_env_t<ex::__empty_env> tag_invoke(ex::get_env_t, const ATailReceiver&) {
return {{}};
friend ex::__empty_env tag_invoke(ex::get_env_t, const ATailReceiver&) {
return {};
}
};

Expand All @@ -83,8 +83,8 @@ struct ANestTailReceiver {
++*__self.called;
return __self.nested_tail_sender;
}
friend ex::__debug_env_t<ex::__empty_env> tag_invoke(ex::get_env_t, const ANestTailReceiver&) {
return {{}};
friend ex::__empty_env tag_invoke(ex::get_env_t, const ANestTailReceiver&) {
return {};
}
};

Expand Down