Searched refs:readHead (Results 1 – 1 of 1) sorted by relevance
194 private var readHead = 0 in newReadHead() variable200 get() = readHead.also { checkThread() } in newReadHead()204 readHead = v in newReadHead()230 val index = pollForIndexReadLocked(timeoutMs, readHead, predicate) in newReadHead()231 readHead = if (index < 0) size else index + 1 in newReadHead()242 fun peek(): E? = getOrNull(readHead).also { checkThread() } in newReadHead()