Lines Matching defs:current
96 private volatile ByteBuffer current;
116 // Returns the current byte buffer to read from.
117 // If the current buffer has no remaining data, will take the
121 private ByteBuffer current() throws IOException {
122 while (current == null || !current.hasRemaining()) {
127 if (current == LAST) break;
133 current = buffers.take();
143 if (current == LAST) break;
154 assert current == LAST || current.hasRemaining();
155 return current;
163 if ((buffer = current()) == LAST) return -1;
166 // in the current buffer.
178 if ((buffer = current()) == LAST) return -1;