diff options
author | Claudius "keldu" Holeksa <mail@keldu.de> | 2024-03-15 13:11:51 +0100 |
---|---|---|
committer | Claudius "keldu" Holeksa <mail@keldu.de> | 2024-03-15 13:11:51 +0100 |
commit | c3c914828a4db958893aaf307cc79d9aaf970431 (patch) | |
tree | 0242ebec7d873f8185217bea3b4e02bfd3536fda /modules/async/c++/async.hpp | |
parent | 7dc6c28f72893dd428a4b5b39a34c5c6b85965a2 (diff) |
async, io: Fixing async tests for io
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 |