59                         std::unique_ptr<ResultChannelReceiver>* receiver,  in createBurst()  argument
64     ASSERT_NE(nullptr, receiver);  in createBurst()
92     *receiver = std::move(fmqResultChannel);  in createBurst()
104     std::unique_ptr<ResultChannelReceiver> receiver;  in createBurstWithResultChannelLength()  local
107     ASSERT_NO_FATAL_FAILURE(createBurst(preparedModel, callback, &sender, &receiver, &context,  in createBurstWithResultChannelLength()
110     ASSERT_NE(nullptr, receiver.get());  in createBurstWithResultChannelLength()
114     *controller = std::make_shared<ExecutionBurstController>(std::move(sender), std::move(receiver),  in createBurstWithResultChannelLength()
121 static void validate(RequestChannelSender* sender, ResultChannelReceiver* receiver,  in validate()  argument
139     auto results = receiver->getBlocking();  in validate()
179 static void removeDatumTest(RequestChannelSender* sender, ResultChannelReceiver* receiver,  in removeDatumTest()  argument
183         validate(sender, receiver, message, serialized,  in removeDatumTest()
192 static void addDatumTest(RequestChannelSender* sender, ResultChannelReceiver* receiver,  in addDatumTest()  argument
199             validate(sender, receiver, message, serialized,  in addDatumTest()
221 static void mutateDatumTest(RequestChannelSender* sender, ResultChannelReceiver* receiver,  in mutateDatumTest()  argument
230                 validate(sender, receiver, message, serialized,  in mutateDatumTest()
245     std::unique_ptr<ResultChannelReceiver> receiver;  in validateBurstSerialization()  local
248     ASSERT_NO_FATAL_FAILURE(createBurst(preparedModel, callback, &sender, &receiver, &context));  in validateBurstSerialization()
250     ASSERT_NE(nullptr, receiver.get());  in validateBurstSerialization()
270     removeDatumTest(sender.get(), receiver.get(), serialized);  in validateBurstSerialization()
271     addDatumTest(sender.get(), receiver.get(), serialized);  in validateBurstSerialization()
272     mutateDatumTest(sender.get(), receiver.get(), serialized);  in validateBurstSerialization()
371     std::unique_ptr<ResultChannelReceiver> receiver;  in validateBurstSanitized()  local
374     ASSERT_NO_FATAL_FAILURE(createBurst(preparedModel, callback, &sender, &receiver, &context));  in validateBurstSanitized()
376     ASSERT_NE(nullptr, receiver.get());  in validateBurstSanitized()
390     auto serialized = receiver->getPacketBlocking();  in validateBurstSanitized()