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

Add more remaining nested unit tests to the any strategy

Browse Source
This commit is contained in:
Denis Blank 2018-03-09 08:13:50 +01:00
parent c4cb102795
commit 1ce251483c
4 changed files with 23 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
include/continuable/detail/composition-any.hpp
View File

@ -151,7 +151,7 @@ struct continuable_dispatcher {
template <typename Continuable,
std::enable_if_t<base::is_continuable<
std::decay_t<Continuable>>::value>* = nullptr>
void operator()(Continuable&& continuable) const {
void operator()(Continuable&& continuable) {
// Retrieve a callback from the submitter and attach it to the continuable
std::forward<Continuable>(continuable)
.next(submitter->create_callback())

9
test/playground/test-playground.cpp
View File

@ -176,13 +176,4 @@ int main(int, char**) {
.then([](int) {
});
{
container::flat_variant<int, float> var;
var = 1;
var = 1.f;
}
int i = 0;
}

4
test/unit-test/multi/test-continuable-connection-all-seq.hpp
View File

@ -75,8 +75,8 @@ void test_all_seq_aggregate(Supplier&& supply, AggregateConnector&& ag) {
}
{
using type_t = decltype(
std::declval<Supplier>()(std::declval<int>(), std::declval<int>()));
using type_t = std::decay_t<decltype(
std::declval<Supplier>()(std::declval<int>(), std::declval<int>()))>;
auto chain = ag(std::make_tuple(
std::vector<type_t>{supply(1, 2), supply(3, 4), supply(5, 6)}));

20
test/unit-test/multi/test-continuable-connection-any.cpp
View File

@ -21,6 +21,8 @@
SOFTWARE.
**/
#include <type_traits>
#include <test-continuable.hpp>
TYPED_TEST(single_dimension_tests, is_logical_any_connectable) {
@ -57,6 +59,24 @@ TYPED_TEST(single_dimension_tests, is_logical_any_connectable) {
ASSERT_ASYNC_TYPES(std::move(chain), tag1, tag2, tag3);
}
{
auto chain =
cti::when_any(std::make_tuple(this->supply(1, 2),
std::make_tuple(this->supply(3, 4))),
this->supply(5, 6));
EXPECT_ASYNC_RESULT(std::move(chain), 1, 2);
}
{
using type_t = std::decay_t<decltype(std::declval<TestFixture>().supply(
std::declval<int>(), std::declval<int>()))>;
std::vector<type_t> v{this->supply(1, 2), this->supply(3, 4),
this->supply(5, 6)};
auto chain = cti::when_any(std::make_tuple(std::move(v)));
EXPECT_ASYNC_RESULT(std::move(chain), 1, 2);
}
{
// Check the evaluation order
unsigned i = 0;