Commit 5c1c33ec authored by Dominik Charousset's avatar Dominik Charousset

Add `make_source` overload without handshake args

parent 68a8290e
...@@ -430,6 +430,16 @@ public: ...@@ -430,6 +430,16 @@ public:
std::move(done), std::move(xs)); std::move(done), std::move(xs));
} }
template <class... Ts, class Init, class Pull, class Done,
class Scatterer =
broadcast_scatterer<typename stream_source_trait_t<Pull>::output>,
class Trait = stream_source_trait_t<Pull>>
output_stream<typename Trait::output, detail::decay_t<Ts>...>
make_source(Init init, Pull pull, Done done,
policy::arg<Scatterer> scatterer_type = {}) {
return make_source(std::make_tuple(), init, pull, done, scatterer_type);
}
template <class Driver, class Input, class... Ts> template <class Driver, class Input, class... Ts>
stream_result<typename Driver::output_type> make_sink(const stream<Input>& in, stream_result<typename Driver::output_type> make_sink(const stream<Input>& in,
Ts&&... xs) { Ts&&... xs) {
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment