Function TEST

pj_runtime/tests/data_processors_runtime_host_test.cpp:71–86

}

TEST(DataProcessorsRuntimeHostTest, CreateRunsTransformViaAbi) {
  Fixture fx;
  fx.seed("speed", {-1.0, 2.0, -3.0});
  DataProcessorsRuntimeHost bridge(fx.service, "pluginA");
  sdk::DataProcessorsHostView view(bridge.raw());

  ASSERT_TRUE(view.valid());
  const auto status = createNegate(view, "negate", "speed", "speed/out");
  ASSERT_TRUE(status) << status.error();

  const auto recipes = fx.service.transformRecipes();
  ASSERT_EQ(recipes.size(), 1u);
  const auto& recipe = recipes.front();
  EXPECT_EQ(recipe.key, "pluginA/negate");
  EXPECT_EQ(readValues(fx.engine, recipe.output_topic_ids.front()), (std::vector<double>{1.0, -2.0, 3.0}));
}

TEST(DataProcessorsRuntimeHostTest, ListAndConfigRoundTrip) {
  Fixture fx;