Package com.hazelcast.config
Class ConfigStream
- java.lang.Object
-
- java.io.InputStream
-
- com.hazelcast.config.ConfigStream
-
- All Implemented Interfaces:
java.io.Closeable
,java.lang.AutoCloseable
public class ConfigStream extends java.io.InputStream
Stream wrapping or copying a genericInputStream
for theConfigRecognizer
API. The purpose of this class is to make the providedInputStream
resetable so that multipleConfigRecognizer
implementations can iterate over the stream. There are even basicInputStream
implementations that don't supportInputStream.reset()
such asBufferedInputStream
. If callingreset()
on the provided implementation fails with an exception, this class reads the stream into abyte[]
and delegates allInputStream
method calls to aByteArrayInputStream
created with thisbyte[]
. To prevent OOM issues, the size of thisbyte[]
is limited to 4096 bytes. This limit can be configured in the constructor.- See Also:
ConfigRecognizer
-
-
Constructor Summary
Constructors Constructor Description ConfigStream(java.io.InputStream configStream)
ConfigStream(java.io.InputStream configStream, int readLimit)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description int
available()
void
close()
void
mark(int readlimit)
boolean
markSupported()
int
read()
int
read(byte[] b)
int
read(byte[] b, int off, int len)
void
reset()
long
skip(long n)
-
-
-
Method Detail
-
read
public int read() throws java.io.IOException
- Specified by:
read
in classjava.io.InputStream
- Throws:
java.io.IOException
-
read
public int read(byte[] b) throws java.io.IOException
- Overrides:
read
in classjava.io.InputStream
- Throws:
java.io.IOException
-
read
public int read(byte[] b, int off, int len) throws java.io.IOException
- Overrides:
read
in classjava.io.InputStream
- Throws:
java.io.IOException
-
skip
public long skip(long n) throws java.io.IOException
- Overrides:
skip
in classjava.io.InputStream
- Throws:
java.io.IOException
-
available
public int available() throws java.io.IOException
- Overrides:
available
in classjava.io.InputStream
- Throws:
java.io.IOException
-
close
public void close() throws java.io.IOException
- Specified by:
close
in interfacejava.lang.AutoCloseable
- Specified by:
close
in interfacejava.io.Closeable
- Overrides:
close
in classjava.io.InputStream
- Throws:
java.io.IOException
-
mark
public void mark(int readlimit)
- Overrides:
mark
in classjava.io.InputStream
-
reset
public void reset() throws java.io.IOException
- Overrides:
reset
in classjava.io.InputStream
- Throws:
java.io.IOException
-
markSupported
public boolean markSupported()
- Overrides:
markSupported
in classjava.io.InputStream
-
-