Searched refs:fmqResultChannel (Results 1 – 4 of 4) sorted by relevance
447 std::unique_ptr<FmqResultChannel> fmqResultChannel = in create() local450 if (!fmqResultChannel->isValid()) { in create()454 if (fmqResultChannel->getEventFlagWord() == nullptr) { in create()459 return std::make_unique<ResultChannelSender>(std::move(fmqResultChannel)); in create()462 ResultChannelSender::ResultChannelSender(std::unique_ptr<FmqResultChannel> fmqResultChannel) in ResultChannelSender() argument463 : mFmqResultChannel(std::move(fmqResultChannel)) {} in ResultChannelSender()
240 std::unique_ptr<FmqResultChannel> fmqResultChannel = in create() local242 if (!fmqResultChannel->isValid()) { in create()247 const FmqResultDescriptor* descriptor = fmqResultChannel->getDesc(); in create()249 std::make_unique<ResultChannelReceiver>(std::move(fmqResultChannel), pollingTimeWindow), in create()253 ResultChannelReceiver::ResultChannelReceiver(std::unique_ptr<FmqResultChannel> fmqResultChannel, in ResultChannelReceiver() argument255 : mFmqResultChannel(std::move(fmqResultChannel)), kPollingTimeWindow(pollingTimeWindow) {} in ResultChannelReceiver()
170 ResultChannelSender(std::unique_ptr<FmqResultChannel> fmqResultChannel);
140 ResultChannelReceiver(std::unique_ptr<FmqResultChannel> fmqResultChannel,