coffee/continuable
1
0
Fork 0
mirror of https://github.com/Naios/continuable.git synced 2025-12-07 01:06:44 +08:00
Code Issues Packages Projects Releases Wiki Activity

Add a r-value overload of freeze

Browse Source 
* Add checks for ensuring the propagation of the frozen property
This commit is contained in:
Denis Blank 2017-03-03 13:53:12 +01:00
parent bf4335d602
commit fae3d42ee0
2 changed files with 26 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
include/continuable/continuable-base.hpp
View File

@ -1510,16 +1510,12 @@ public:
/// \endcond
/// The destructor automatically invokes the continuable_base
/// if it wasn't released yet.
/// if it wasn't consumed yet.
///
/// In order to invoke the continuable early you may call the
/// continuable_base::done() method.
///
/// You may release the continuable_base through calling the corresponding
/// continuable_base::release method which prevents
/// the invocation on destruction but also makes the object unusable.
///
/// The continuable_base::freeze method just disables the automatic
/// The continuable_base::freeze method disables the automatic
/// invocation on destruction without invalidating the object.
///
/// \since version 1.0.0
@ -1772,7 +1768,7 @@ public:
return detail::transforms::as_future(std::move(*this).materialize());
}
/// Invokes the continuation chain before the continuabl_base
/// Invokes the continuation chain before the continuable_base
/// is destructed. This will release the object.
///
/// \see continuable_base::~continuable_base() for further details about
@ -1788,7 +1784,7 @@ public:
///
/// \returns Returns true when the continuable_base is frozen.
///
/// \see continuable_base::freeze() for further details.
/// \see continuable_base::freeze for further details.
///
/// \note This method will trigger an assertion if the
/// continuable_base was released already.
@ -1815,7 +1811,16 @@ public:
/// continuable_base was released already.
///
/// \since version 1.0.0
void freeze(bool enabled = true) noexcept { ownership_.freeze(enabled); }
continuable_base& freeze(bool enabled = true) & noexcept {
ownership_.freeze(enabled);
return *this;
}
/// \copydoc continuable_base::freeze
continuable_base&& freeze(bool enabled = true) && noexcept {
ownership_.freeze(enabled);
return std::move(*this);
}
private:
void release() noexcept { ownership_.release(); }

12
test/unit-test/test-continuable-base.cpp
View File

@ -90,6 +90,18 @@ TYPED_TEST(single_dimension_tests, are_not_finished_when_not_continued) {
}
}
TYPED_TEST(single_dimension_tests, freeze_is_kept_across_the_chain) {
{
auto chain = this->supply().freeze().then([=] { return this->supply(); });
ASSERT_TRUE(chain.is_frozen());
}
{
auto chain = this->supply().freeze().then(this->supply());
ASSERT_TRUE(chain.is_frozen());
}
}
TYPED_TEST(single_dimension_tests, are_chainable) {
EXPECT_ASYNC_RESULT(this->supply().then([] {
return; // void