#include <fn.hpp>
Public Types | |
| using | value_type = typename InGen::value_type |
| using | queue_t = mt::synchronized_queue< maybe< value_type >, mt::lockables::atomic_mutex > |
Public Member Functions | |
| auto | operator() () -> maybe< value_type > |
Public Attributes | |
| InGen | in_gen |
| const size_t | queue_size |
| std::unique_ptr< queue_t > | queue |
| std::future< void > | fut |
| using rangeless::fn::impl::async_wr::gen< InGen >::queue_t = mt::synchronized_queue<maybe<value_type>, mt::lockables::atomic_mutex> |
| using rangeless::fn::impl::async_wr::gen< InGen >::value_type = typename InGen::value_type |
|
inline |
| std::future<void> rangeless::fn::impl::async_wr::gen< InGen >::fut |
| InGen rangeless::fn::impl::async_wr::gen< InGen >::in_gen |
| std::unique_ptr<queue_t> rangeless::fn::impl::async_wr::gen< InGen >::queue |
| const size_t rangeless::fn::impl::async_wr::gen< InGen >::queue_size |