Skip to content

Commit 23ab4b8

Browse files
committed
Merge branch 'add-merge_each' into marbletesting
2 parents 0fc8423 + ce05c8f commit 23ab4b8

File tree

2 files changed

+4
-6
lines changed

2 files changed

+4
-6
lines changed

include/exec/sequence/merge_each.hpp

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -436,7 +436,7 @@ namespace exec {
436436
&& __nothrow_connectable<__error_next_sender_t, __error_next_receiver_t>) {
437437
auto __next_sender = exec::set_next(__receiver_, __error_sender_t{this});
438438
auto __next_receiver = __error_next_receiver_t{
439-
this, __env_fn{&__receiver_, &__nested_stop_}
439+
this, __env_fn_t{&__receiver_, &__nested_stop_}
440440
};
441441
__error_op_.__emplace_from([&]() {
442442
return stdexec::connect(
@@ -448,7 +448,7 @@ namespace exec {
448448
STDEXEC_TRY {
449449
auto __next_sender = exec::set_next(__receiver_, __error_sender_t{this});
450450
auto __next_receiver = __error_next_receiver_t{
451-
this, __env_fn{&__receiver_, &__nested_stop_}
451+
this, __env_fn_t{&__receiver_, &__nested_stop_}
452452
};
453453
__error_op_.__emplace_from([&]() {
454454
return stdexec::connect(

test/exec/sequence/test_merge_each_threaded.cpp

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -290,9 +290,8 @@ namespace {
290290
return count;
291291
}))));
292292

293+
CAPTURE(count < 40, count > 4);
293294
CHECK(v.has_value() == false);
294-
CHECK(count < 40);
295-
CHECK(count > 4);
296295
}
297296

298297
TEST_CASE(
@@ -362,9 +361,8 @@ namespace {
362361
return count;
363362
}))));
364363

364+
CAPTURE(count < 40, count > 4);
365365
CHECK(v.has_value() == false);
366-
CHECK(count < 40);
367-
CHECK(count > 4);
368366
}
369367

370368
#endif // STDEXEC_HAS_STD_RANGES()

0 commit comments

Comments
 (0)