|
template<class RET , class FUNC , class ... ARGS> |
static Function< int(Traits::Yield &)> | bindCaller (std::shared_ptr< Context< RET >> ctx, FUNC &&func0, ARGS &&...args0) |
|
template<class RET , class FUNC , class ... ARGS> |
static Function< int()> | bindIoCaller (std::shared_ptr< Promise< RET >> promise, FUNC &&func0, ARGS &&...args0) |
|
template<class RET , class INPUT_IT > |
static int | forEachCoro (CoroContextPtr< std::vector< RET >> ctx, INPUT_IT inputIt, size_t num, const Functions::ForEachFunc< RET, INPUT_IT > &func) |
|
template<class RET , class INPUT_IT > |
static int | forEachBatchCoro (CoroContextPtr< std::vector< std::vector< RET >>> ctx, INPUT_IT inputIt, size_t num, const Functions::ForEachFunc< RET, INPUT_IT > &func, size_t numCoroutineThreads) |
|
template<class KEY , class MAPPED_TYPE , class REDUCED_TYPE , class INPUT_IT > |
static int | mapReduceCoro (CoroContextPtr< std::map< KEY, REDUCED_TYPE >> ctx, INPUT_IT inputIt, size_t num, const Functions::MapFunc< KEY, MAPPED_TYPE, INPUT_IT > &mapper, const Functions::ReduceFunc< KEY, MAPPED_TYPE, REDUCED_TYPE > &reducer) |
|
template<class KEY , class MAPPED_TYPE , class REDUCED_TYPE , class INPUT_IT > |
static int | mapReduceBatchCoro (CoroContextPtr< std::map< KEY, REDUCED_TYPE >> ctx, INPUT_IT inputIt, size_t num, const Functions::MapFunc< KEY, MAPPED_TYPE, INPUT_IT > &mapper, const Functions::ReduceFunc< KEY, MAPPED_TYPE, REDUCED_TYPE > &reducer) |
|
Utility to bind a user callable function unto a coroutine or an IO task.
- Note
- For internal use only.