(ByteBuffer dst)
| 121 | } |
| 122 | |
| 123 | int consume(ByteBuffer dst) { |
| 124 | ByteBuffer slice = buffer.slice(); |
| 125 | int limit = Math.min(slice.remaining(), dst.remaining()); |
| 126 | ((Buffer) slice).limit(limit); |
| 127 | dst.put(slice); |
| 128 | discard(limit); |
| 129 | return limit; |
| 130 | } |
| 131 | |
| 132 | @Override |
| 133 | public void close() throws IOException { |