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