Searched defs:messageQueue (Results 1 – 6 of 6) sorted by relevance
105 ot::MessageQueue messageQueue; in TestMessageQueue() local
174 ot::MessageQueue messageQueue; in TestPriorityQueue() local
67 protected LinkedList messageQueue; field in UDPMessageProcessor
30 internal val messageQueue = ScheduledMessageQueue() in <lambda>() constant in kotlinx.coroutines.SetTimeoutBasedDispatcher
1352 private int verifyMessageCountAndClose(BlockingQueue<InputStream> messageQueue, int count) in verifyMessageCountAndClose()1897 private final BlockingQueue<InputStream> messageQueue = new LinkedBlockingQueue<InputStream>(); field in AbstractTransportTest.ServerStreamListenerBase1957 private final BlockingQueue<InputStream> messageQueue = new LinkedBlockingQueue<InputStream>(); field in AbstractTransportTest.ClientStreamListenerBase
276 MessageQueue *messageQueue = GetMessageQueue(); in GetNext() local