@Test public void testTwoChunksWrite() throws IOException { int size = ChunkedOutputStream.MAX_ARRAY_SIZE + 1; for (int i = 0; i < size; ++i) { stream.write(i); } int counter = 0; for (byte[] chunk: assertFinishedStream(size, 2)) { for (byte actual: chunk) { assertEquals((byte) counter++, actual); } } }
@Override @SuppressWarnings("checkstyle:ParameterName") public void write(final int b) throws IOException { checkNotClosed(); ensureOneByte(); currentChunk[currentOffset] = (byte) b; currentOffset++; size++; }
ChunkedOutputStream extends OutputStream { @Override @SuppressWarnings("checkstyle:ParameterName") public void write(final int b) throws IOException { checkNotClosed(); ensureOneByte(); currentChunk[currentOffset] = (byte) b; currentOffset++; size++; } }
ChunkedOutputStream extends OutputStream { @Override @SuppressWarnings("checkstyle:ParameterName") public void write(final int b) throws IOException { checkNotClosed(); ensureOneByte(); currentChunk[currentOffset] = (byte) b; currentOffset++; size++; } ChunkedOutputStream(final int requestedInitialCapacity); }
ChunkedOutputStream extends OutputStream { @Override @SuppressWarnings("checkstyle:ParameterName") public void write(final int b) throws IOException { checkNotClosed(); ensureOneByte(); currentChunk[currentOffset] = (byte) b; currentOffset++; size++; } ChunkedOutputStream(final int requestedInitialCapacity); @Override @SuppressWarnings("checkstyle:ParameterName") void write(final int b); @Override @SuppressWarnings("checkstyle:ParameterName") void write(final byte[] b, final int off, final int len); @Override void close(); }
ChunkedOutputStream extends OutputStream { @Override @SuppressWarnings("checkstyle:ParameterName") public void write(final int b) throws IOException { checkNotClosed(); ensureOneByte(); currentChunk[currentOffset] = (byte) b; currentOffset++; size++; } ChunkedOutputStream(final int requestedInitialCapacity); @Override @SuppressWarnings("checkstyle:ParameterName") void write(final int b); @Override @SuppressWarnings("checkstyle:ParameterName") void write(final byte[] b, final int off, final int len); @Override void close();  }