coffee/continuable
1
0
Fork 0
mirror of https://github.com/Naios/continuable.git synced 2025-12-09 10:16:43 +08:00
Code Issues Packages Projects Releases Wiki Activity

some minor improvements

Browse Source
This commit is contained in:
Naios 2015-06-11 17:46:44 +02:00
parent b5c3d7d0a8
commit e5a3c1fbcd
2 changed files with 15 additions and 67 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
fluent/Continuable.h
View File

@ -27,7 +27,10 @@ namespace detail
} // detail
template <typename... Args>
struct ContinuableState
struct ContinuableState;
template <typename... Args>
struct ContinuableState<Args...>
{
};
@ -41,12 +44,11 @@ public:
typedef std::function<void(Callback<_ATy...>&&)> ForwardFunction;
private:
// Function which expects a callback that is inserted from the Continuable
// Functional which expects a callback that is inserted from the Continuable
// to chain everything together
ForwardFunction _callback_insert;
bool released;
bool _released;
void Dispatch()
{
@ -55,26 +57,27 @@ private:
public:
/// Deleted copy construct
template <typename _RCTy, typename _RState>
Continuable(Continuable<_RCTy, _RState> const&) = delete;
explicit Continuable(Continuable<_RCTy, _RState> const&) = delete;
/// Move construct
template <typename _RCTy, typename _RState>
Continuable(Continuable<_RCTy, _RState>&& right) : released(right.released)
explicit Continuable(Continuable<_RCTy, _RState>&& right)
: _released(right._released)
{
right.released = true;
right._released = true;
}
// Construct through a ForwardFunction
template<typename _FTy>
Continuable(_FTy&& callback_insert)
: _callback_insert(std::forward<_FTy>(callback_insert)), released(false) { }
: _callback_insert(std::forward<_FTy>(callback_insert)), _released(false) { }
/// Destructor which calls the dispatch chain if needed.
~Continuable()
{
if (!released)
if (!_released)
{
released = true;
_released = true;
Dispatch();
}
}
@ -87,8 +90,8 @@ public:
template <typename _RCTy, typename _RState>
Continuable& operator= (Continuable<_RCTy, _RState>&& right)
{
released = right.released;
right.released = true;
_released = right._released;
right._released = true;
return *this;
}

55
fluent/fluent++.hpp
View File

@ -9,61 +9,6 @@
#include "functional_unwrap.hpp"
/*
class fluent_step
{
bool released;
void release()
{
int i = 0;
std::cout << "-> release" << std::endl;
}
public:
fluent_step() : released(false)
{
std::cout << "+ construct" << std::endl;
}
~fluent_step()
{
std::cout << "- destruct" << std::endl;
if (!released)
release();
}
fluent_step(fluent_step const&) = delete;
fluent_step(fluent_step&& right) : released(false)
{
std::cout << "<-> move" << std::endl;
right.released = true;
}
fluent_step& operator= (fluent_step const&) = delete;
fluent_step& operator= (fluent_step&& right)
{
released = false;
right.released = true;
return *this;
}
template <typename Callback>
fluent_step then(Callback&& callback)
{
return std::move(*this);
}
};
template <typename _ATy = void()>
fluent_step make_waterfall()
{
return fluent_step();
}
struct ProtoContinueable
{
template <typename Callback>