Searched refs:fmqResultChannel (Results 1 – 4 of 4) sorted by relevance
458 std::unique_ptr<FmqResultChannel> fmqResultChannel = in create() local461 if (!fmqResultChannel->isValid()) { in create()465 if (fmqResultChannel->getEventFlagWord() == nullptr) { in create()470 return std::make_unique<ResultChannelSender>(std::move(fmqResultChannel)); in create()473 ResultChannelSender::ResultChannelSender(std::unique_ptr<FmqResultChannel> fmqResultChannel) in ResultChannelSender() argument474 : mFmqResultChannel(std::move(fmqResultChannel)) {} in ResultChannelSender()
244 std::unique_ptr<FmqResultChannel> fmqResultChannel = in create() local246 if (!fmqResultChannel->isValid()) { in create()251 const FmqResultDescriptor* descriptor = fmqResultChannel->getDesc(); in create()253 std::make_unique<ResultChannelReceiver>(std::move(fmqResultChannel), pollingTimeWindow), in create()257 ResultChannelReceiver::ResultChannelReceiver(std::unique_ptr<FmqResultChannel> fmqResultChannel, in ResultChannelReceiver() argument259 : mFmqResultChannel(std::move(fmqResultChannel)), kPollingTimeWindow(pollingTimeWindow) {} in ResultChannelReceiver()
170 ResultChannelSender(std::unique_ptr<FmqResultChannel> fmqResultChannel);
140 ResultChannelReceiver(std::unique_ptr<FmqResultChannel> fmqResultChannel,