@Test public void closeThenReadShouldBeInvalid() throws IOException { Buffer src = DEFAULT_RO_ALLOCATOR.fromAscii("1234"); try (InputStream stream = new CloseableIteratorBufferAsInputStream(createIterator(src))) { stream.close(); expected.expect(instanceOf(IOException.class)); stream.read(); } }
@Override public void close() throws IOException { leftover = CLOSED; super.close(); }
CloseableIteratorBufferAsInputStream extends AbstractCloseableIteratorAsInputStream<Buffer> { @Override public void close() throws IOException { leftover = CLOSED; super.close(); } }
CloseableIteratorBufferAsInputStream extends AbstractCloseableIteratorAsInputStream<Buffer> { @Override public void close() throws IOException { leftover = CLOSED; super.close(); } CloseableIteratorBufferAsInputStream(CloseableIterator<Buffer> iterator); }
CloseableIteratorBufferAsInputStream extends AbstractCloseableIteratorAsInputStream<Buffer> { @Override public void close() throws IOException { leftover = CLOSED; super.close(); } CloseableIteratorBufferAsInputStream(CloseableIterator<Buffer> iterator); @Override void close(); }
CloseableIteratorBufferAsInputStream extends AbstractCloseableIteratorAsInputStream<Buffer> { @Override public void close() throws IOException { leftover = CLOSED; super.close(); } CloseableIteratorBufferAsInputStream(CloseableIterator<Buffer> iterator); @Override void close();  }