Skip to content
Open
Show file tree
Hide file tree
Changes from 1 commit
Commits
Show all changes
48 commits
Select commit Hold shift + click to select a range
aa8d882
Add debug and static-member-fn support to sequence-sender
kirkshoop Sep 30, 2025
4e37d4d
switch `__seqexpr` to use static-member-fn to customize `subscribe` a…
kirkshoop Sep 30, 2025
fef35d8
add `__well_formed_sequence_sender` constraints to `ignore_all_values…
kirkshoop Sep 30, 2025
f7da526
improve debugging for `transform_each`
kirkshoop Sep 30, 2025
082a9e4
move sequence ERROR structs into exec namespace
kirkshoop Sep 30, 2025
4cca273
add `merge` algorithm for sequence-senders
kirkshoop Sep 30, 2025
ef85ae8
fix bugs in merge and transform_each
kirkshoop Oct 12, 2025
86c2afb
apply PR feedback
kirkshoop Oct 12, 2025
b3ca212
remove requires clause that was preventing diagnosis of failed type c…
kirkshoop Oct 12, 2025
bb09c37
diagnostics improvements for sequence sender
kirkshoop Oct 12, 2025
3f1ba21
add merge_each sequence sender adaptor
kirkshoop Oct 12, 2025
5117f8b
provide aliases for exec::materialize_t and exec::dematerialize_t
kirkshoop Oct 18, 2025
d63efcf
fix compiler error construction in merge
kirkshoop Oct 18, 2025
41a2f09
fix some ordering and error handling issues in merge_each
kirkshoop Oct 18, 2025
28d9367
improve compile errors for sequence senders
kirkshoop Oct 18, 2025
be05244
prevent trailing return types from causing subscribe, get_completion_…
kirkshoop Oct 18, 2025
b1b1614
add the option to specify a scheduler to iterate.
kirkshoop Oct 18, 2025
84b041f
add test_scheduler and marble and notification
kirkshoop Oct 18, 2025
b70a136
Merge branch 'main' into addmerge
ericniebler Oct 19, 2025
da25787
remove windows-only compilation error debug aid that is breaking wind…
kirkshoop Oct 21, 2025
54e46e2
replace static_thread_pool with single_thread_context. static_thread_…
kirkshoop Oct 29, 2025
3229813
Merge branch 'main' into addmerge
ericniebler Oct 29, 2025
8364f1a
clang-format changes
kirkshoop Oct 29, 2025
f58736e
remove _t from concept name
kirkshoop Oct 29, 2025
431c67c
simplify meta expression at the behest of Visual Studio
kirkshoop Oct 29, 2025
825110f
compile time debug changes
kirkshoop Oct 29, 2025
73d3cb0
Merge branch 'addmerge' into add-merge_each
kirkshoop Oct 29, 2025
9c71ef2
fix crash in delays_each_on
kirkshoop Oct 31, 2025
71da7d9
Merge remote-tracking branch 'origin/addmerge' into add-merge_each
kirkshoop Oct 31, 2025
36b00e2
clang-format changes
kirkshoop Oct 31, 2025
3cbf83b
fix bad copy/paste
kirkshoop Oct 31, 2025
ec14797
clang-format changes
kirkshoop Oct 31, 2025
dbd27ac
Merge branch 'add-merge_each' into marbletesting
kirkshoop Oct 31, 2025
09c57f3
update transform_iterate to work with specified scheduler support in …
kirkshoop Nov 1, 2025
6bed02b
silence visual studio unreachable warnings
kirkshoop Nov 1, 2025
9fd303d
fix visual studio errors
kirkshoop Nov 1, 2025
a309693
fixes visual studio compile errors and runtime crashes
kirkshoop Nov 1, 2025
3d93782
fix delays_each_on
kirkshoop Nov 1, 2025
175e734
fix clang19 build
kirkshoop Nov 1, 2025
ff06ec6
Merge remote-tracking branch 'upstream/main' into add-merge_each
kirkshoop Nov 1, 2025
f8841c5
fix bad merge
kirkshoop Nov 1, 2025
0fc8423
Merge branch 'add-merge_each' into marbletesting
kirkshoop Nov 1, 2025
2b48dfe
how did this ever compile?
kirkshoop Nov 1, 2025
ce05c8f
remove checks in multithreaded tests that cause test failures on slow…
kirkshoop Nov 1, 2025
23ab4b8
Merge branch 'add-merge_each' into marbletesting
kirkshoop Nov 1, 2025
850a25c
fixes warnings and errors in clang16
kirkshoop Nov 2, 2025
50d6ce7
get nvhpc compiling
kirkshoop Nov 6, 2025
307ead3
Merge branch 'add-merge_each' into marbletesting
kirkshoop Nov 7, 2025
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
fix visual studio errors
  • Loading branch information
kirkshoop committed Nov 1, 2025
commit 9fd303d6e3d63ca69fb27b647f7485e89476fbac
38 changes: 29 additions & 9 deletions include/exec/sequence/marbles.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -100,9 +100,9 @@ namespace exec {
return __lhs.__c_ == __rhs.__c_;
}

friend std::string to_string(const __value_t& __self) noexcept {
using std::to_string;
return "'" + std::string{1, __self.__c_} + "'";
friend inline std::string to_string(const __value_t& __self) noexcept {
const char __result[4] = {'\'', __self.__c_, '\'', '\0'};
return __result;
}
};

Expand All @@ -122,41 +122,59 @@ namespace exec {
operator marble_selector_t() const noexcept {
return marble_selector_t::sequence_start;
}
friend inline std::string to_string(sequence_start_t) noexcept {
return {"sequence_start"};
}
};
static constexpr inline sequence_start_t sequence_start;

struct sequence_connect_t {
operator marble_selector_t() const noexcept {
return marble_selector_t::sequence_connect;
}
friend inline std::string to_string(sequence_connect_t) noexcept {
return {"sequence_connect"};
}
};
static constexpr inline sequence_connect_t sequence_connect;

struct sequence_end_t {
operator marble_selector_t() const noexcept {
return marble_selector_t::sequence_value;
}
friend inline std::string to_string(sequence_end_t) noexcept {
return {"sequence_end"};
}
};
static constexpr inline sequence_end_t sequence_end;

struct sequence_error_t {
operator marble_selector_t() const noexcept {
return marble_selector_t::sequence_error;
}
friend inline std::string to_string(sequence_error_t) noexcept {
return {"sequence_error"};
}
};
static constexpr inline sequence_error_t sequence_error;

struct sequence_stopped_t {
operator marble_selector_t() const noexcept {
return marble_selector_t::sequence_stopped;
}
friend inline std::string to_string(sequence_stopped_t) noexcept {
return {"sequence_stopped"};
}
};
static constexpr inline sequence_stopped_t sequence_stopped;

struct request_stop_t {
operator marble_selector_t() const noexcept {
return marble_selector_t::request_stop;
}
friend inline std::string to_string(request_stop_t) noexcept {
return {"request_stop"};
}
};
static constexpr inline request_stop_t request_stop;

Expand Down Expand Up @@ -490,8 +508,11 @@ namespace exec {
break;
}
default: {
long __consumed_in_default = 0;
if (__whole.begin() == __remaining.begin() || !!std::isspace(__remaining.front())) {
// use auto and math to derive the difference type
auto __consumed_in_default = __remaining.begin() - __remaining.begin();
if (
std::addressof(*__whole.begin()) == std::addressof(*__remaining.begin())
|| !!std::isspace(__remaining.front())) {
if (!!std::isspace(__remaining.front())) {
__consume_first(1);
++__consumed_in_default;
Expand All @@ -508,7 +529,7 @@ namespace exec {
if (
__suffix_begin != __remaining.end() && __suffix_begin - __remaining.begin() > 0
&& __all_digits) {
long __to_consume = __suffix_begin - __remaining.begin();
auto __to_consume = __suffix_begin - __remaining.begin();
long __duration = std::atol(__remaining.data());
if (std::ranges::equal(
__remaining.subspan(__to_consume, 3), __make_span("ms "_mstr))) {
Expand Down Expand Up @@ -800,6 +821,8 @@ namespace exec {

} // namespace __marbles

using __value_t = __marbles::__value_t;

using sequence_start_t = __marbles::sequence_start_t;
static constexpr inline auto sequence_start = sequence_start_t{};

Expand Down Expand Up @@ -829,9 +852,6 @@ namespace exec {

static constexpr inline auto record_marbles = record_marbles_t{};

namespace __marbles {

}
} // namespace exec

namespace stdexec {
Expand Down
41 changes: 24 additions & 17 deletions include/exec/sequence/notification.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,7 @@
#include "stdexec/__detail/__config.hpp"
#include "stdexec/__detail/__tuple.hpp"
#include <concepts>
#include <string>

namespace exec {
namespace __notification {
Expand Down Expand Up @@ -116,13 +117,13 @@ namespace exec {
template <class _Receiver>
void visit_receiver(_Receiver&& __receiver) noexcept {
std::visit(
[&__receiver](auto&& __tuple) noexcept {
[&__receiver]<class _Tuple>(_Tuple&& __tuple) noexcept {
__tuple.apply(
[&__receiver](auto __tag, auto&&... __args) noexcept {
[&__receiver]<class _Tag, class... _Args>(_Tag __tag, _Args&&... __args) noexcept {
__tag(
static_cast<_Receiver&&>(__receiver), static_cast<decltype(__args)&&>(__args)...);
static_cast<_Receiver&&>(__receiver), static_cast<_Args&&>(__args)...);
},
static_cast<decltype(__tuple)&&>(__tuple));
static_cast<_Tuple&&>(__tuple));
},
static_cast<__notification_t&&>(__notification_));
}
Expand Down Expand Up @@ -156,25 +157,31 @@ namespace exec {
friend auto
operator==(const notification_t& __lhs, const notification_t& __rhs) noexcept -> bool {
return std::visit(
[]<class _Lhs, class _Rhs>(const _Lhs& __lhs, const _Rhs& __rhs) noexcept {
[]<class _Lhs, class _Rhs>(const _Lhs& __lhs, const _Rhs& __rhs) noexcept -> bool {
using __lhs_tag_t = notification_t::__tag_of_t<_Lhs>;
using __rhs_tag_t = notification_t::__tag_of_t<_Rhs>;
if constexpr (
!std::same_as<__tag_of_t<_Lhs>, __tag_of_t<_Rhs>>
!std::same_as<__lhs_tag_t, __rhs_tag_t>
|| stdexec::__v<stdexec::__mapply<stdexec::__msize, _Lhs>>
!= stdexec::__v<stdexec::__mapply<stdexec::__msize, _Rhs>>) {
return false;
} else {
return __lhs.apply(
[&__rhs]<class _LTag, class... _LArgs>(_LTag, const _LArgs&... __l_args) {
return __rhs.apply(
[&]<class _RTag, class... _RArgs>(_RTag, const _RArgs&... __r_args) {
if constexpr ((std::equality_comparable_with<const _LArgs&, const _RArgs&>
&& ... && true)) {
return ((__l_args == __r_args) && ... && true);
} else {
return false;
}
},
__rhs);
[&__lhs,
&__rhs]<class _LTag, class... _LArgs>(_LTag, const _LArgs&...) noexcept -> bool {
return [&__lhs, &__rhs]<std::size_t... _Is>(__indices<_Is...>) {
if constexpr ((std::equality_comparable_with<
const decltype(_Lhs::template __get<_Is+1>(__lhs))&,
const decltype(_Rhs::template __get<_Is+1>(__rhs))&
>
&& ... && true)) {
return (
((_Lhs::template __get<_Is+1>(__lhs)) == (_Rhs::template __get<_Is+1>(__rhs)))
&& ... && true);
} else {
return false;
}
}(__indices_for<_LArgs...>{});
},
__lhs);
}
Expand Down
21 changes: 0 additions & 21 deletions test/test_common/sequences.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -56,27 +56,6 @@ namespace exec::__sequence_sender {
}
} // namespace exec::__sequence_sender

namespace exec::__marbles {
inline std::string to_string(sequence_start_t) noexcept {
return {"sequence_start"};
}
inline std::string to_string(sequence_connect_t) noexcept {
return {"sequence_connect"};
}
inline std::string to_string(sequence_end_t) noexcept {
return {"sequence_end"};
}
inline std::string to_string(sequence_error_t) noexcept {
return {"sequence_error"};
}
inline std::string to_string(sequence_stopped_t) noexcept {
return {"sequence_stopped"};
}
inline std::string to_string(request_stop_t) noexcept {
return {"request_stop"};
}
} // namespace exec::__marbles

namespace Catch {
template <class _Clock, class _Duration>
struct StringMaker<std::chrono::time_point<_Clock, _Duration>> {
Expand Down