Searched defs:historyQueue (Results 1 – 2 of 2) sorted by relevance
47 DirHistoryQueue* historyQueue; variable
74 LinkedBlockingQueue<PushEvent<? extends LogEntry>> historyQueue = new LinkedBlockingQueue<>(); in createStream() local