coffee/continuable
1
0
Fork 0
mirror of https://github.com/Naios/continuable.git synced 2026-02-16 15:19:48 +08:00
Code Issues Packages Projects Releases Wiki Activity

Worked on multiple function invocation

Browse Source
This commit is contained in:
Naios 2015-07-02 16:45:01 +02:00
parent 45aa2237c1
commit 5454f480df
1 changed files with 37 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

48
include/Continuable.h
View File

@ -488,13 +488,13 @@ namespace detail
multiple_result_maker<0, fu::identity<>, fu::identity<>, Args...>; multiple_result_maker<0, fu::identity<>, fu::identity<>, Args...>;
}; };
template<typename Args> template<typename _ATy, typename _RTy>
struct multiple_when_all_chainer_t_make_result; struct multiple_when_all_chainer_t_make_result;
template<typename... Args> template<typename... _ATy, typename... _RTy>
struct multiple_when_all_chainer_t_make_result<fu::identity<Args...>> struct multiple_when_all_chainer_t_make_result<fu::identity<_ATy...>, fu::identity<_RTy...>>
{ {
typedef Continuable<Args...> continuable_t; typedef Continuable<_RTy...> continuable_t;
typedef std::function<continuable_t()> return_t; typedef std::function<continuable_t()> return_t;
@ -505,19 +505,45 @@ namespace detail
std::size_t count; std::size_t count;
std::tuple<Args...> result; std::tuple<_RTy...> result;
}; };
template <typename... _ATy, typename... _CTy> typedef std::shared_ptr<ResultStorage> SharedResult;
template <typename _CTy>
static void invoke(SharedResult storage, _CTy&& functional)
{
}
// Invoke last
template <typename _CTy>
static void distribute_invoke(SharedResult storage, _CTy&& current)
{
invoke(storage, std::forward<_CTy>(current));
}
// Invoke and pass recursive to next
template <typename _CTy, typename... Rest>
static void distribute_invoke(SharedResult storage, _CTy&& current, Rest&&... rest)
{
invoke(storage, std::forward<_CTy>(current));
distribute_invoke(storage, std::forward<Rest>(rest)...);
}
/// Creates a faked function which invokes all sub continuables
template <typename... _CTy>
static return_t create(_CTy&&... functionals) static return_t create(_CTy&&... functionals)
{ {
return [=](_ATy&&... args) return [=](_ATy&&... args) mutable
{ {
// Fake continuable which wraps all continuables together // Fake continuable which wraps all continuables together
return make_continuable([](Callback<Args...>&& callback) return make_continuable([=](Callback<_RTy...>&& callback) mutable
{ {
std::shared_ptr<ResultStorage> result( SharedResult result(new ResultStorage(sizeof...(_CTy)));
new ResultStorage(sizeof...(_CTy)));
distribute_invoke(result, std::forward<_CTy>(functionals)...);
// functional_traits<_ATy...>::correct(std::forward<_CTy>(functionals))
// auto shared = std::make_shared(ResultStorage()); // auto shared = std::make_shared(ResultStorage());
@ -542,7 +568,7 @@ namespace detail
static std::size_t const size = result_maker::size; static std::size_t const size = result_maker::size;
typedef multiple_when_all_chainer_t_make_result<arguments_t> make_result; typedef multiple_when_all_chainer_t_make_result<fu::identity<_ATy...>, arguments_t> make_result;
// Creates one continuable from multiple ones // Creates one continuable from multiple ones
static auto make_when_all(_CTy&&... args) static auto make_when_all(_CTy&&... args)