MySQL Connector/J 9.2.0 · com.mysql.cj.protocol.x.ContinuousInputStream

Modifier and Type	Field and Description
private boolean	closed
private Queue<InputStream>	inputStreams

Access	Constructor and Description
protected	ContinuousInputStream(InputStream in)

Method Summary

Modifier and Type	Method and Description
protected boolean	Returns: `true` if the element was added to the `InputStream`s queue. addInputStream(InputStream the `InputStream` to add. newIn) Adds another `InputStream` to the `InputStream`s queue.
public int	Returns: the number of bytes available. available() Overrides java.io.FilterInputStream.available. Returns the number of bytes available in the active underlying `InputStream`.
public void	close() Overrides java.io.FilterInputStream.close. Implements java.io.Closeable.close. Closes this stream and all underlying `InputStream`s.
private void	ensureOpen() Ensures that this `InputStream` wasn't closed yet.
private boolean	Returns: `true` if the currently active `InputStream` was replaced by a new one. nextInLine() Closes the currently active `InputStream` and replaces it by the the head of the `InputStream`s queue.
public int	read() Overrides java.io.FilterInputStream.read. Reads one byte from the underlying `InputStream`.
public int	read(byte[] the buffer into which the data is read. b) Overrides java.io.FilterInputStream.read. Forwards the read to `read(byte[], int, int)`.
public int	read(byte[] the buffer into which the data is read. b, int the start offset in array `b` at which the data is written. off, int the maximum number of bytes to read. len) Overrides java.io.FilterInputStream.read. Reads bytes from the underlying `InputStream`.

Inherited from java.io.FilterInputStream:: mark markSupported reset skip

closed	back to summary
private boolean closed

inputStreams	back to summary
private Queue<InputStream> inputStreams

ContinuousInputStream	back to summary
protected ContinuousInputStream(InputStream in)

Method Detail

addInputStream back to summary

addInputStream	back to summary
protected boolean addInputStream(InputStream newIn) Adds another `InputStream` to the `InputStream`s queue. Parameters newIn:InputStream the `InputStream` to add. Returns:boolean `true` if the element was added to the `InputStream`s queue.

protected boolean addInputStream(InputStream newIn)

Adds another InputStream to the InputStreams queue.

Parameters

newIn:InputStream: the InputStream to add.

Returns:boolean

true if the element was added to the InputStreams queue.

available back to summary

available	back to summary
public int available() throws IOException Overrides java.io.FilterInputStream.available. Returns the number of bytes available in the active underlying `InputStream`. Returns:int the number of bytes available. Annotations @Override Exceptions IOException: Doc from java.io.FilterInputStream.available. if an I/O error occurs. See Also `FilterInputStream#available()`

public int available() throws IOException

Overrides java.io.FilterInputStream.available.

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

Returns:int

the number of bytes available.

Annotations

@Override

Exceptions

IOException:

Doc from java.io.FilterInputStream.available.

if an I/O error occurs.

See Also

FilterInputStream#available()

close back to summary

close	back to summary
public void close() throws IOException Overrides java.io.FilterInputStream.close. Implements java.io.Closeable.close. Closes this stream and all underlying `InputStream`s. Annotations @Override Exceptions IOException: Doc from java.io.FilterInputStream.close. if an I/O error occurs. See Also `FilterInputStream#close()`

public void close() throws IOException

Overrides java.io.FilterInputStream.close.

Implements java.io.Closeable.close.

Closes this stream and all underlying InputStreams.

Annotations

@Override

Exceptions

IOException:

Doc from java.io.FilterInputStream.close.

if an I/O error occurs.

See Also

FilterInputStream#close()

ensureOpen back to summary

ensureOpen	back to summary
private void ensureOpen() throws IOException Ensures that this `InputStream` wasn't closed yet. Exceptions IOException: if this `InputStream` was closed.

private void ensureOpen() throws IOException

Ensures that this InputStream wasn't closed yet.

Exceptions

IOException:: if this InputStream was closed.

nextInLine back to summary

nextInLine	back to summary
private boolean nextInLine() throws IOException Closes the currently active `InputStream` and replaces it by the the head of the `InputStream`s queue. Returns:boolean `true` if the currently active `InputStream` was replaced by a new one. Exceptions IOException: if errors occur while closing the currently active `InputStream`.

private boolean nextInLine() throws IOException

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

Returns:boolean

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

Exceptions

IOException:: if errors occur while closing the currently active InputStream.

read back to summary

read	back to summary
public int read() throws IOException Overrides java.io.FilterInputStream.read. Reads one byte from the underlying `InputStream`. When EOF is reached, then reads from the next `InputStream` in the queue. Returns:int Doc from java.io.FilterInputStream.read. the next byte of data, or `-1` if the end of the stream is reached. Annotations @Override Exceptions IOException: Doc from java.io.FilterInputStream.read. if an I/O error occurs. See Also `FilterInputStream#read()`

public int read() throws IOException

Overrides java.io.FilterInputStream.read.

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

Returns:int

Doc from java.io.FilterInputStream.read.

the next byte of data, or -1 if the end of the stream is reached.

Annotations

@Override

Exceptions

IOException:

Doc from java.io.FilterInputStream.read.

if an I/O error occurs.

See Also

FilterInputStream#read()

read back to summary

read	back to summary
public int read(byte[] b) throws IOException Overrides java.io.FilterInputStream.read. Forwards the read to `read(byte[], int, int)`. Parameters b:byte[] Doc from java.io.FilterInputStream.read. the buffer into which the data is read. Returns:int Doc from java.io.FilterInputStream.read. the total number of bytes read into the buffer, or `-1` if there is no more data because the end of the stream has been reached. Annotations @Override Exceptions IOException: Doc from java.io.FilterInputStream.read. if an I/O error occurs. See Also `FilterInputStream#read(byte[])`

public int read(byte[] b) throws IOException

Overrides java.io.FilterInputStream.read.

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

Parameters

b:byte[]

Doc from java.io.FilterInputStream.read.

the buffer into which the data is read.

Returns:int

Doc from java.io.FilterInputStream.read.

the total number of bytes read into the buffer, or -1 if there is no more data because the end of the stream has been reached.

Annotations

@Override

Exceptions

IOException:

Doc from java.io.FilterInputStream.read.

if an I/O error occurs.

See Also

FilterInputStream#read(byte[])

read back to summary

read	back to summary
public int read(byte[] b, int off, int len) throws IOException Overrides java.io.FilterInputStream.read. Reads bytes from the underlying `InputStream`. When EOF is reached, then reads from the next `InputStream` in the queue. Parameters b:byte[] Doc from java.io.FilterInputStream.read. the buffer into which the data is read. off:int Doc from java.io.FilterInputStream.read. the start offset in array `b` at which the data is written. len:int Doc from java.io.FilterInputStream.read. the maximum number of bytes to read. Returns:int Doc from java.io.FilterInputStream.read. the total number of bytes read into the buffer, or `-1` if there is no more data because the end of the stream has been reached. Annotations @Override Exceptions IOException: Doc from java.io.FilterInputStream.read. if an I/O error occurs. See Also `FilterInputStream#read(byte[], int, int)`