Searched refs:EmitQ (Results 1 – 2 of 2) sorted by relevance
365 void emitQueueNotifyEnd() { EmitQ.notifyEnd(); } in emitQueueNotifyEnd()498 BoundedProducerConsumerQueue<EmitterWorkItem> EmitQ; variable
313 EmitQ(/*Sequential=*/getFlags().isSequential()), in GlobalContext()992 EmitQ.blockingPush(std::move(Item)); in emitQueueBlockingPush()1000 return EmitQ.blockingPop(); in emitQueueBlockingPop()