Package io.servicetalk.concurrent.api.internal

Class CloseableIteratorBufferAsInputStream

java.lang.Object

java.io.InputStream

io.servicetalk.concurrent.internal.AbstractCloseableIteratorAsInputStream<Buffer>

io.servicetalk.concurrent.api.internal.CloseableIteratorBufferAsInputStream

All Implemented Interfaces:

Closeable, AutoCloseable

public final class CloseableIteratorBufferAsInputStream
extends AbstractCloseableIteratorAsInputStream<Buffer>

Conversion from a CloseableIterator of Buffers to a InputStream.

Constructor Summary

Constructors

Constructor	Description
CloseableIteratorBufferAsInputStream(CloseableIterator<Buffer> iterator)	Create a new instance.

Method Summary

Modifier and Type	Method	Description
void	close()
protected boolean	hasLeftOver()	Determine if there are left over bytes buffered.
protected boolean	isClosed()	Determine if AbstractCloseableIteratorAsInputStream.close() has been called.
protected void	leftOverCheckReset()	Check if the left over buffer needs to be reset.
protected int	leftOverReadableBytes()	Get the number of readable bytes in the left over buffer.
protected void	leftOverReadBytes(byte[] dst, int offset, int length)	Read bytes from the left over buffer into b.
protected byte	leftOverReadSingleByte()	Read a single byte from the left over buffer.
protected void	leftOverReset()	Reset the left over buffer.
protected void	nextLeftOver(CloseableIterator<Buffer> iterator)	Read the next element from the Iterator.

Methods inherited from class io.servicetalk.concurrent.internal.AbstractCloseableIteratorAsInputStream

available, markSupported, read, read

Methods inherited from class java.io.InputStream

mark, nullInputStream, read, readAllBytes, readNBytes, readNBytes, reset, skip, skipNBytes, transferTo

Methods inherited from class java.lang.Object

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

Constructor Details

CloseableIteratorBufferAsInputStream

public CloseableIteratorBufferAsInputStream(CloseableIterator<Buffer> iterator)

Create a new instance.

Parameters:

iterator - The CloseableIterator providing data.

Method Details

leftOverReadableBytes

protected int leftOverReadableBytes()

Description copied from class: AbstractCloseableIteratorAsInputStream

Get the number of readable bytes in the left over buffer.

Specified by:

leftOverReadableBytes in class AbstractCloseableIteratorAsInputStream<Buffer>

Returns:

the number of readable bytes in the left over buffer.

leftOverReadBytes

protected void leftOverReadBytes(byte[] dst,
 int offset,
 int length)

Description copied from class: AbstractCloseableIteratorAsInputStream

Read bytes from the left over buffer into b.

Specified by:

leftOverReadBytes in class AbstractCloseableIteratorAsInputStream<Buffer>

Parameters:

dst - The destination to read to.

offset - The offset to read into for dst.

length - The amount of bytes to read from the left over buffer.

hasLeftOver

protected boolean hasLeftOver()

Description copied from class: AbstractCloseableIteratorAsInputStream

Determine if there are left over bytes buffered.

Specified by:

hasLeftOver in class AbstractCloseableIteratorAsInputStream<Buffer>

Returns:

true if there are left over bytes buffered.

leftOverCheckReset

protected void leftOverCheckReset()

Description copied from class: AbstractCloseableIteratorAsInputStream

Check if the left over buffer needs to be reset.

Specified by:

leftOverCheckReset in class AbstractCloseableIteratorAsInputStream<Buffer>

leftOverReset

protected void leftOverReset()

Description copied from class: AbstractCloseableIteratorAsInputStream

Reset the left over buffer.

Specified by:

leftOverReset in class AbstractCloseableIteratorAsInputStream<Buffer>

nextLeftOver

protected void nextLeftOver(CloseableIterator<Buffer> iterator)

Description copied from class: AbstractCloseableIteratorAsInputStream

Read the next element from the Iterator.

Specified by:

nextLeftOver in class AbstractCloseableIteratorAsInputStream<Buffer>

Parameters:

iterator - The CloseableIterator to get the next element from.

leftOverReadSingleByte

protected byte leftOverReadSingleByte()

Description copied from class: AbstractCloseableIteratorAsInputStream

Read a single byte from the left over buffer.

Specified by:

leftOverReadSingleByte in class AbstractCloseableIteratorAsInputStream<Buffer>

Returns:

a single byte from the left over buffer.

isClosed

protected boolean isClosed()

Description copied from class: AbstractCloseableIteratorAsInputStream

Determine if AbstractCloseableIteratorAsInputStream.close() has been called.

Specified by:

isClosed in class AbstractCloseableIteratorAsInputStream<Buffer>

Returns:

true if AbstractCloseableIteratorAsInputStream.close() has been called.

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Overrides:

close in class AbstractCloseableIteratorAsInputStream<Buffer>

Throws:

IOException