#include <fn.hpp>
Classes | |
struct | value_type_callable |
Public Types | |
using | value_type = decltype(map_fn(std::move(*gen()))) |
using | future_like_t = decltype(async(value_type_callable{})) |
using | queue_t = std::deque< future_like_t > |
Public Member Functions | |
auto | operator() () -> maybe< value_type > |
Public Attributes | |
InGen | gen |
const Async | async |
const F | map_fn |
const size_t | queue_cap |
queue_t | queue |
using rangeless::fn::impl::par_transform< F, Async >::gen< InGen >::future_like_t = decltype(async(value_type_callable{})) |
using rangeless::fn::impl::par_transform< F, Async >::gen< InGen >::queue_t = std::deque<future_like_t> |
using rangeless::fn::impl::par_transform< F, Async >::gen< InGen >::value_type = decltype(map_fn(std::move(*gen()))) |
|
inline |
const Async rangeless::fn::impl::par_transform< F, Async >::gen< InGen >::async |
InGen rangeless::fn::impl::par_transform< F, Async >::gen< InGen >::gen |
const F rangeless::fn::impl::par_transform< F, Async >::gen< InGen >::map_fn |
queue_t rangeless::fn::impl::par_transform< F, Async >::gen< InGen >::queue |
const size_t rangeless::fn::impl::par_transform< F, Async >::gen< InGen >::queue_cap |