#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 |