Searched defs:messageQueue (Results 1 – 7 of 7) sorted by relevance
67 protected LinkedList messageQueue; field in UDPMessageProcessor
107 MessageQueue messageQueue; in TestMessageQueue() local
175 MessageQueue messageQueue; in TestPriorityQueue() local
30 internal val messageQueue = ScheduledMessageQueue() in <lambda>() constant in kotlinx.coroutines.SetTimeoutBasedDispatcher
84 @Nullable private Queue<InputStream> messageQueue; field in Outbound
1495 private int verifyMessageCountAndClose(BlockingQueue<InputStream> messageQueue, int count) in verifyMessageCountAndClose()2228 private final BlockingQueue<InputStream> messageQueue = new LinkedBlockingQueue<>(); field in AbstractTransportTest.ServerStreamListenerBase2288 private final BlockingQueue<InputStream> messageQueue = new LinkedBlockingQueue<>(); field in AbstractTransportTest.ClientStreamListenerBase
275 MessageQueue *messageQueue = GetMessageQueue(); in GetNext() local