diff --git a/src/main/java/org/gaul/s3proxy/NullBlobStore.java b/src/main/java/org/gaul/s3proxy/NullBlobStore.java index 09a099b..cbfbb03 100644 --- a/src/main/java/org/gaul/s3proxy/NullBlobStore.java +++ b/src/main/java/org/gaul/s3proxy/NullBlobStore.java @@ -194,9 +194,20 @@ final class NullBlobStore extends ForwardingBlobStore { } private static final class NullInputStream extends InputStream { + private boolean closed; + @Override public int read() throws IOException { + if (closed) { + throw new IOException("Stream already closed"); + } return 0; } + + @Override + public void close() throws IOException { + super.close(); + closed = true; + } } }