coffee/continuable
1
0
Fork 0
mirror of https://github.com/Naios/continuable.git synced 2026-02-11 04:39:50 +08:00
Code Issues Packages Projects Releases Wiki Activity

more work

Browse Source
This commit is contained in:
Naios 2015-06-15 02:06:46 +02:00
parent 29e107ed1b
commit b747d439d8
1 changed files with 22 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
fluent/Continuable.h
View File

@ -47,12 +47,28 @@ namespace detail
struct convert_void_to_continuable<void> struct convert_void_to_continuable<void>
{ {
typedef _ContinuableImpl<DefaultContinuableState, Callback<>> type; typedef _ContinuableImpl<DefaultContinuableState, Callback<>> type;
template<typename Fn, typename... Args>
static type InvokeAndReturn(std::function<Fn> const& functional, std::forward<Args>... args)
{
functional(std::forward<Args>(args)...);
return type(); /*[](Callback<>&& callback)
{
callback();
});*/
}
}; };
template<typename _State, typename _CTy> template<typename _State, typename _CTy>
struct convert_void_to_continuable<_ContinuableImpl<_State, _CTy>> struct convert_void_to_continuable<_ContinuableImpl<_State, _CTy>>
{ {
typedef _ContinuableImpl<_State, _CTy> type; typedef _ContinuableImpl<_State, _CTy> type;
template<typename Fn, typename... Args>
static type InvokeAndReturn(std::function<Fn> const& functional, std::forward<Args>... args)
{
return functional(std::forward<Args>(args)...);
}
}; };
template<typename _NextRTy, typename... _NextATy> template<typename _NextRTy, typename... _NextATy>
@ -156,6 +172,8 @@ namespace detail
return *this; return *this;
} }
template<typename _CTy> template<typename _CTy>
auto then(_CTy&& functional) auto then(_CTy&& functional)
-> typename unary_chainer_t<_CTy>::result_t -> typename unary_chainer_t<_CTy>::result_t
@ -165,15 +183,17 @@ namespace detail
// next(unary_chainer_t<_CTy>::callback_t()); // next(unary_chainer_t<_CTy>::callback_t());
return typename unary_chainer_t<_CTy>::result_t return typename unary_chainer_t<_CTy>::result_t
(std::move(*this), [=](typename unary_chainer_t<_CTy>::callback_t&& /*next_insert_callback*/) (std::move(*this), [=](typename unary_chainer_t<_CTy>::callback_t&& next_insert_callback)
{ {
_callback_insert([=](_ATy... args) _callback_insert([=](_ATy... args)
{ {
// typename unary_chainer_t<_CTy>::result_t next = typename unary_chainer_t<_CTy>::result_t next =
functional(std::forward<_ATy>(args)...); functional(std::forward<_ATy>(args)...);
// next_insert_callback(result.); // next_insert_callback(result.);
// next._insert_callback(next_insert_callback); // next._insert_callback(next_insert_callback);
// FIXME Call next callback
}); });
}); });
} }