Skip to content

Commit

Permalink
Remove change to a separate PR.
Browse files Browse the repository at this point in the history
Signed-off-by: Michał Zientkiewicz <mzient@gmail.com>
  • Loading branch information
mzient committed Jun 24, 2024
1 parent f9c2f3a commit 679f9e3
Showing 1 changed file with 0 additions and 29 deletions.
29 changes: 0 additions & 29 deletions dali/core/exec/tasking_test.cc
Original file line number Diff line number Diff line change
Expand Up @@ -254,35 +254,6 @@ TEST(TaskingTest, MultiOutputIterable) {
EXPECT_EQ(ret, 1 + 3 + 42 + 5 + 10);
}

TEST(TaskingTest, MultiOutputIterableOfAny) {
Executor ex(4);
ex.Start();
auto producer = Task::Create(2, []() {
return std::vector<std::any>{1.0, 42};
});

auto consumer1 = Task::Create([](Task *t) {
return t->GetInputValue<double>(0) + 3;
});
consumer1->Subscribe(producer, 0);

auto consumer2 = Task::Create([](Task *t) {
return t->GetInputValue<int>(0) + 5;
});
consumer2->Subscribe(producer, 1);

auto apex = Task::Create([](Task *t) {
return t->GetInputValue<double>(0) + t->GetInputValue<int>(1) + 10;
});
apex->Subscribe(consumer1)->Subscribe(consumer2);

ex.AddSilentTask(producer);
ex.AddSilentTask(consumer1);
ex.AddSilentTask(consumer2);
int ret = ex.AddTask(apex).Value<double>();
EXPECT_EQ(ret, 1 + 3 + 42 + 5 + 10);
}

TEST(TaskingTest, MultiOutputTuple) {
Executor ex(4);
ex.Start();
Expand Down

0 comments on commit 679f9e3

Please sign in to comment.