diff options
Diffstat (limited to 'modules/async/c++/async.hpp')
| -rw-r--r-- | modules/async/c++/async.hpp | 9 |
1 files changed, 6 insertions, 3 deletions
diff --git a/modules/async/c++/async.hpp b/modules/async/c++/async.hpp index 257fbd7..b56742c 100644 --- a/modules/async/c++/async.hpp +++ b/modules/async/c++/async.hpp @@ -166,10 +166,12 @@ public: error operator()(error &&err); }; +/** + * Helper object holding a sink_conveyor_node<void> + */ class conveyor_sink { private: own<conveyor_node> node_; - public: conveyor_sink(); conveyor_sink(own<conveyor_node> &&node); @@ -246,7 +248,7 @@ public: [[nodiscard]] conveyor<T> limit(size_t val = 1); /** - * + * @todo implement */ [[nodiscard]] std::pair<conveyor<T>, merge_conveyor<T>> merge(); @@ -257,9 +259,10 @@ public: */ template <typename ErrorFunc = propagate_error> void detach(ErrorFunc &&err_func = propagate_error()); + /** * Creates a local sink which drops elements, but lifetime control remains - * in your hand. + * in your hand contrary to detach(). */ template <typename ErrorFunc = propagate_error> [[nodiscard]] conveyor_sink |