64                         std::unique_ptr<ResultChannelReceiver>* receiver,  in createBurst()  argument
69     ASSERT_NE(nullptr, receiver);  in createBurst()
98     *receiver = std::move(fmqResultChannel);  in createBurst()
110     std::unique_ptr<ResultChannelReceiver> receiver;  in createBurstWithResultChannelLength()  local
113     ASSERT_NO_FATAL_FAILURE(createBurst(preparedModel, callback, &sender, &receiver, &context,  in createBurstWithResultChannelLength()
116     ASSERT_NE(nullptr, receiver.get());  in createBurstWithResultChannelLength()
120     *controller = std::make_shared<ExecutionBurstController>(std::move(sender), std::move(receiver),  in createBurstWithResultChannelLength()
127 static void validate(RequestChannelSender* sender, ResultChannelReceiver* receiver,  in validate()  argument
145     auto results = receiver->getBlocking();  in validate()
185 static void removeDatumTest(RequestChannelSender* sender, ResultChannelReceiver* receiver,  in removeDatumTest()  argument
189         validate(sender, receiver, message, serialized,  in removeDatumTest()
198 static void addDatumTest(RequestChannelSender* sender, ResultChannelReceiver* receiver,  in addDatumTest()  argument
205             validate(sender, receiver, message, serialized,  in addDatumTest()
227 static void mutateDatumTest(RequestChannelSender* sender, ResultChannelReceiver* receiver,  in mutateDatumTest()  argument
236                 validate(sender, receiver, message, serialized,  in mutateDatumTest()
251     std::unique_ptr<ResultChannelReceiver> receiver;  in validateBurstSerialization()  local
254     ASSERT_NO_FATAL_FAILURE(createBurst(preparedModel, callback, &sender, &receiver, &context));  in validateBurstSerialization()
256     ASSERT_NE(nullptr, receiver.get());  in validateBurstSerialization()
276     removeDatumTest(sender.get(), receiver.get(), serialized);  in validateBurstSerialization()
277     addDatumTest(sender.get(), receiver.get(), serialized);  in validateBurstSerialization()
278     mutateDatumTest(sender.get(), receiver.get(), serialized);  in validateBurstSerialization()
377     std::unique_ptr<ResultChannelReceiver> receiver;  in validateBurstSanitized()  local
380     ASSERT_NO_FATAL_FAILURE(createBurst(preparedModel, callback, &sender, &receiver, &context));  in validateBurstSanitized()
382     ASSERT_NE(nullptr, receiver.get());  in validateBurstSanitized()
396     auto serialized = receiver->getPacketBlocking();  in validateBurstSanitized()