Searched refs:fmqResultChannel (Results 1 – 6 of 6) sorted by relevance
239 std::unique_ptr<FmqResultChannel> fmqResultChannel = in create() local241 if (!fmqResultChannel->isValid()) { in create()246 const FmqResultDescriptor* descriptor = fmqResultChannel->getDesc(); in create()248 std::make_unique<ResultChannelReceiver>(std::move(fmqResultChannel), pollingTimeWindow), in create()252 ResultChannelReceiver::ResultChannelReceiver(std::unique_ptr<FmqResultChannel> fmqResultChannel, in ResultChannelReceiver() argument254 : mFmqResultChannel(std::move(fmqResultChannel)), kPollingTimeWindow(pollingTimeWindow) {} in ResultChannelReceiver()
452 std::unique_ptr<FmqResultChannel> fmqResultChannel = in create() local455 if (!fmqResultChannel->isValid()) { in create()459 if (fmqResultChannel->getEventFlagWord() == nullptr) { in create()464 return std::make_unique<ResultChannelSender>(std::move(fmqResultChannel)); in create()467 ResultChannelSender::ResultChannelSender(std::unique_ptr<FmqResultChannel> fmqResultChannel) in ResultChannelSender() argument468 : mFmqResultChannel(std::move(fmqResultChannel)) {} in ResultChannelSender()
70 auto [fmqResultChannel, fmqResultDescriptor] = in createBurst()73 ASSERT_NE(nullptr, fmqResultChannel.get()); in createBurst()92 *receiver = std::move(fmqResultChannel); in createBurst()
75 auto [fmqResultChannel, fmqResultDescriptor] = in createBurst()78 ASSERT_NE(nullptr, fmqResultChannel.get()); in createBurst()98 *receiver = std::move(fmqResultChannel); in createBurst()
170 ResultChannelSender(std::unique_ptr<FmqResultChannel> fmqResultChannel);
140 ResultChannelReceiver(std::unique_ptr<FmqResultChannel> fmqResultChannel,