Skip to content

Commit a137868

Browse files
committed
clang-format
1 parent b497050 commit a137868

File tree

2 files changed

+19
-25
lines changed

2 files changed

+19
-25
lines changed

include/beman/execution/detail/schedule_from.hpp

Lines changed: 9 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -130,16 +130,15 @@ struct impls_for<::beman::execution::detail::schedule_from_t> : ::beman::executi
130130
::std::monostate,
131131
::beman::execution::detail::meta::transform<
132132
::beman::execution::detail::as_tuple_t,
133-
::beman::execution::detail::meta::to<
134-
::std::variant,
135-
::beman::execution::detail::meta::combine<
136-
::beman::execution::completion_signatures_of_t<
137-
::beman::execution::detail::child_type<Sender>,
138-
::beman::execution::env_of_t<Receiver>>,
139-
//-dk:TODO get proper error completion signatures
140-
::beman::execution::completion_signatures<::beman::execution::set_error_t(
141-
::std::exception_ptr),
142-
::beman::execution::set_stopped_t()>>>>>>;
133+
::beman::execution::detail::meta::to<::std::variant,
134+
::beman::execution::detail::meta::combine<
135+
::beman::execution::completion_signatures_of_t<
136+
::beman::execution::detail::child_type<Sender>,
137+
::beman::execution::env_of_t<Receiver>>,
138+
//-dk:TODO get proper error completion signatures
139+
::beman::execution::completion_signatures<
140+
::beman::execution::set_error_t(::std::exception_ptr),
141+
::beman::execution::set_stopped_t()>>>>>>;
143142

144143
return state_type<Receiver, sched_t, variant_t>(sch, receiver);
145144
}};

tests/beman/execution/issue-174.test.cpp

Lines changed: 10 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -8,24 +8,19 @@
88
namespace ex = beman::execution;
99

1010
namespace {
11-
struct thread_loop: ex::run_loop {
12-
std::thread thread{[this] { this->run(); }};
13-
~thread_loop() {
14-
this->finish();
15-
this->thread.join();
16-
}
17-
};
18-
}
11+
struct thread_loop : ex::run_loop {
12+
std::thread thread{[this] { this->run(); }};
13+
~thread_loop() {
14+
this->finish();
15+
this->thread.join();
16+
}
17+
};
18+
} // namespace
1919

2020
int main() {
2121
thread_loop ex_context1;
2222
thread_loop ex_context2;
2323

24-
ex::sync_wait(
25-
ex::just()
26-
| ex::then([] { })
27-
| ex::continues_on(ex_context1.get_scheduler())
28-
| ex::then([] { })
29-
| ex::continues_on(ex_context2.get_scheduler()) | ex::then([] {})
30-
);
24+
ex::sync_wait(ex::just() | ex::then([] {}) | ex::continues_on(ex_context1.get_scheduler()) | ex::then([] {}) |
25+
ex::continues_on(ex_context2.get_scheduler()) | ex::then([] {}));
3126
}

0 commit comments

Comments
 (0)