diff options
Diffstat (limited to 'configserver-client/src/main/java/ai/vespa/hosted/client/ForwardingInputStream.java')
-rw-r--r-- | configserver-client/src/main/java/ai/vespa/hosted/client/ForwardingInputStream.java | 55 |
1 files changed, 55 insertions, 0 deletions
diff --git a/configserver-client/src/main/java/ai/vespa/hosted/client/ForwardingInputStream.java b/configserver-client/src/main/java/ai/vespa/hosted/client/ForwardingInputStream.java new file mode 100644 index 00000000000..473dce8ea33 --- /dev/null +++ b/configserver-client/src/main/java/ai/vespa/hosted/client/ForwardingInputStream.java @@ -0,0 +1,55 @@ +// Copyright Verizon Media. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root. +package ai.vespa.hosted.client; + +import java.io.IOException; +import java.io.InputStream; + +import static java.util.Objects.requireNonNull; + +/** + * @author jonmv + */ +public class ForwardingInputStream extends InputStream { + + private final InputStream delegate; + + public ForwardingInputStream(InputStream delegate) { + this.delegate = requireNonNull(delegate); + } + + @Override + public int read() throws IOException { + return delegate.read(); + } + + @Override + public int read(byte[] b, int off, int len) throws IOException { + return delegate.read(b, off, len); + } + + @Override + public int available() throws IOException { + return delegate.available(); + } + + @Override + public void close() throws IOException { + delegate.close(); + } + + @Override + public synchronized void mark(int readlimit) { + delegate.mark(readlimit); + } + + @Override + public synchronized void reset() throws IOException { + delegate.reset(); + } + + @Override + public boolean markSupported() { + return delegate.markSupported(); + } + +} |