com.mysql.cj.protocol.x

Class ContinuousInputStream

java.lang.Object

java.io.InputStream

java.io.FilterInputStream

com.mysql.cj.protocol.x.ContinuousInputStream

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

public class ContinuousInputStream
extends java.io.FilterInputStream

An InputStream wrapper that reads from a queue of underlying InputStreams, giving the impression that all data is coming from a single, continuous, source.

Field Summary

Fields

Modifier and Type	Field and Description
private boolean	closed
private java.util.Queue<java.io.InputStream>	inputStreams

Fields inherited from class java.io.FilterInputStream

in

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	ContinuousInputStream(java.io.InputStream in)

Method Summary

Modifier and Type	Method and Description
protected boolean	addInputStream(java.io.InputStream newIn) Adds another InputStream to the InputStreams queue.
int	available() Returns the number of bytes available in the active underlying InputStream.
void	close() Closes this stream and all underlying InputStreams.
private void	ensureOpen() Ensures that this InputStream wasn't closed yet.
private boolean	nextInLine() Closes the currently active InputStream and replaces it by the the head of the InputStreams queue.
int	read() Reads one byte from the underlying InputStream.
int	read(byte[] b) Forwards the read to read(byte[], int, int).
int	read(byte[] b, int off, int len) Reads bytes from the underlying InputStream.

Methods inherited from class java.io.FilterInputStream

mark, markSupported, reset, skip

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

inputStreams

private java.util.Queue<java.io.InputStream> inputStreams

closed

private boolean closed

Constructor Detail

ContinuousInputStream

protected ContinuousInputStream(java.io.InputStream in)

Method Detail

available

public int available()
              throws java.io.IOException

Returns the number of bytes available in the active underlying InputStream.

Overrides:

available in class java.io.FilterInputStream

Returns:

the number of bytes available.

Throws:

java.io.IOException

See Also:

FilterInputStream.available()

close

public void close()
           throws java.io.IOException

Closes this stream and all underlying InputStreams.

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Overrides:

close in class java.io.FilterInputStream

Throws:

java.io.IOException

See Also:

FilterInputStream.close()

read

public int read()
         throws java.io.IOException

Reads one byte from the underlying InputStream. When EOF is reached, then reads from the next InputStream in the queue.

Overrides:

read in class java.io.FilterInputStream

Throws:

java.io.IOException

See Also:

FilterInputStream.read()

read

public int read(byte[] b)
         throws java.io.IOException

Forwards the read to read(byte[], int, int).

Overrides:

read in class java.io.FilterInputStream

Throws:

java.io.IOException

See Also:

FilterInputStream.read(byte[])

read

public int read(byte[] b,
                int off,
                int len)
         throws java.io.IOException

Reads bytes from the underlying InputStream. When EOF is reached, then reads from the next InputStream in the queue.

Overrides:

read in class java.io.FilterInputStream

Throws:

java.io.IOException

See Also:

FilterInputStream.read(byte[], int, int)

addInputStream

protected boolean addInputStream(java.io.InputStream newIn)

Adds another InputStream to the InputStreams queue.

Parameters:

newIn - the InputStream to add.

Returns:

true if the element was added to the InputStreams queue.

nextInLine

private boolean nextInLine()
                    throws java.io.IOException

Closes the currently active InputStream and replaces it by the the head of the InputStreams queue.

Returns:

true if the currently active InputStream was replaced by a new one.

Throws:

java.io.IOException - if errors occur while closing the currently active InputStream.

ensureOpen

private void ensureOpen()
                 throws java.io.IOException

Ensures that this InputStream wasn't closed yet.

Throws:

java.io.IOException - if this InputStream was closed.