coffee/continuable
1
0
Fork 0
mirror of https://github.com/Naios/continuable.git synced 2026-02-07 18:26:40 +08:00
Code Issues Packages Projects Releases Wiki Activity

test

Browse Source
This commit is contained in:
Naios 2015-06-14 19:03:49 +02:00
parent 8e7fc13698
commit 08b68efc5e
1 changed files with 31 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

45
fluent/Continuable.h
View File

@ -39,7 +39,7 @@ namespace detail
template<typename _STy, typename _CTy> template<typename _STy, typename _CTy>
class _ContinuableImpl; class _ContinuableImpl;
/// Corrects void return types from functional types which should be Continuable<Callback<>> /// Corrects void return types from functional types which should be Continuable<DefaultContinuableState, Callback<>>
template<typename _RTy> template<typename _RTy>
struct convert_void_to_continuable; struct convert_void_to_continuable;
@ -77,14 +77,16 @@ namespace detail
} }
public: public:
// Empty for debugging
_ContinuableImpl()
: _released(false) { }
/// Deleted copy construct /// Deleted copy construct
template<typename _RState, typename _RCTy> _ContinuableImpl(_ContinuableImpl const&) = delete;
_ContinuableImpl(_ContinuableImpl<_RState, _RCTy> const&) = delete;
/// Move construct /// Move construct
template<typename _RState, typename _RCTy> _ContinuableImpl(_ContinuableImpl&& right)
_ContinuableImpl(_ContinuableImpl<_RState, _RCTy>&& right) : _released(right._released), _callback_insert(std::move(right._callback_insert))
: _released(right._released)
{ {
right._released = true; right._released = true;
} }
@ -106,23 +108,38 @@ namespace detail
/// Deleted copy assign /// Deleted copy assign
template<typename _RState, typename _RCTy> template<typename _RState, typename _RCTy>
_ContinuableImpl& operator= (_ContinuableImpl<_RState, _RCTy> const&) = delete; _ContinuableImpl& operator= (_ContinuableImpl const&) = delete;
/// Move construct assign /// Move construct assign
template<typename _RState, typename _RCTy> _ContinuableImpl& operator= (_ContinuableImpl&& right)
_ContinuableImpl& operator= (_ContinuableImpl<_RState, _RCTy>&& right)
{ {
_released = right._released; _released = right._released;
right._released = true; right._released = true;
_callback_insert = std::move(right._callback_insert);
return *this; return *this;
} }
// TODO Accept only correct callbacks template<typename T>
template<typename _CTy> struct unary_chainer;
_ContinuableImpl<DefaultContinuableState, Callback<_ATy...>> then(_CTy&&)
template<typename _NewRTy, typename... _NewATy>
struct unary_chainer<std::function<_NewRTy(_NewATy...)>>
{ {
// TODO Transmute the returned callback here. template<typename _CTy>
return _ContinuableImpl<DefaultContinuableState, Callback<_ATy...>>(std::move(*this)); static auto chain(_CTy&& functional, _ContinuableImpl&& me)
-> typename convert_void_to_continuable<_NewRTy>::type
{
return _ContinuableImpl<ContinuableState<_STy...>, Callback<_NewATy...>>();
}
};
template<typename _CTy>
auto then(_CTy&& functional)
-> decltype(unary_chainer<fu::function_type_of_t<typename std::decay<_CTy>::type>::
chain(std::declval<_CTy>()))
{
return unary_chainer<fu::function_type_of_t<_CTy>>::
chain(std::forward<_CTy>(functional), std::move(*this));
} }
/* /*