Searched refs:nextAvailableQueue (Results 1 – 1 of 1) sorted by relevance
131 private val nextAvailableQueue = SynchronousQueue<Int>() constant143 assertTrue(nextAvailableQueue.offer(newAvailable.coerceIn(0, TEST_FILESIZE), in setAvailable()162 available = nextAvailableQueue.take() in read()