Function TEST

pj_datastore/tests/data_processor_test.cpp:37–46

};

TEST(DataProcessorTest, ApplyBatchRunsEverySample) {
  PassThrough proc;
  std::vector<Sample> in;
  in.push_back(Sample::scalar(1, PJ::VarValue{1.0}));
  in.push_back(Sample::scalar(2, PJ::VarValue{2.0}));
  in.push_back(Sample::scalar(3, PJ::VarValue{3.0}));
  const auto out = proc.applyBatch(in);
  ASSERT_EQ(out.size(), 3u);
  EXPECT_EQ(out[2].raw_ts_ns, 3);
}

TEST(DataProcessorTest, AppendTailAppendsToExistingOutput) {
  PassThrough proc;