Searched refs:mBufferQueue (Results 1 – 1 of 1) sorted by relevance
44 private final ConcurrentBufferQueue<T> mBufferQueue; field in CountableBufferQueue57 mBufferQueue = new ConcurrentBufferQueue<T>(new DecrementingProcessor<T>(processor)); in CountableBufferQueue()83 T result = mBufferQueue.getNext(); in getNext()91 T result = mBufferQueue.getNext(timeout, unit); in getNext()98 return mBufferQueue.peekNext(); in peekNext()103 mBufferQueue.discardNext(); in discardNext()118 mBufferQueue.update(element); in update()128 mBufferQueue.close(); in close()133 return mBufferQueue.isClosed(); in isClosed()