com.ibm.cos.v2.core.internal.io

Class AwsChunkedInputStream

java.lang.Object

java.io.InputStream

com.ibm.cos.v2.core.io.SdkInputStream

com.ibm.cos.v2.core.internal.io.AwsChunkedInputStream

All Implemented Interfaces:

Releasable, Closeable, AutoCloseable

Direct Known Subclasses:

AwsChunkedEncodingInputStream, AwsCompressionInputStream

public abstract class AwsChunkedInputStream
extends SdkInputStream

A wrapper of InputStream that implements streaming in chunks.

Field Summary

Fields

Modifier and Type	Field and Description
protected com.ibm.cos.v2.core.internal.io.ChunkContentIterator	currentChunkIterator Iterator on the current chunk.
static int	DEFAULT_CHUNK_SIZE
protected InputStream	is
protected boolean	isAtStart
protected boolean	isTerminating
protected static Logger	log
protected static int	SKIP_BUFFER_SIZE
protected com.ibm.cos.v2.core.internal.io.UnderlyingStreamBuffer	underlyingStreamBuffer Iterator on the buffer of the underlying stream, Null if the wrapped stream is marksupported, otherwise it will be initialized when this wrapper is marked.

Constructor Summary

Constructors

Constructor and Description
AwsChunkedInputStream()

Method Summary

Modifier and Type	Method and Description
protected InputStream	getWrappedInputStream() Returns the underlying input stream, if any, from the subclass; or null if there is no underlying input stream.
boolean	markSupported()
int	read()
long	skip(long n)

Methods inherited from class com.ibm.cos.v2.core.io.SdkInputStream

abort, abortIfNeeded, release

Methods inherited from class java.io.InputStream

available, close, mark, read, read, reset

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.ibm.cos.v2.core.internal.io.Releasable

release

Field Detail

DEFAULT_CHUNK_SIZE

public static final int DEFAULT_CHUNK_SIZE

See Also:

Constant Field Values

SKIP_BUFFER_SIZE

protected static final int SKIP_BUFFER_SIZE

See Also:

Constant Field Values

log

protected static final Logger log

is

protected InputStream is

currentChunkIterator

protected com.ibm.cos.v2.core.internal.io.ChunkContentIterator currentChunkIterator

Iterator on the current chunk.

underlyingStreamBuffer

protected com.ibm.cos.v2.core.internal.io.UnderlyingStreamBuffer underlyingStreamBuffer

Iterator on the buffer of the underlying stream, Null if the wrapped stream is marksupported, otherwise it will be initialized when this wrapper is marked.

isAtStart

protected boolean isAtStart

isTerminating

protected boolean isTerminating

Constructor Detail

AwsChunkedInputStream

public AwsChunkedInputStream()

Method Detail

read

public int read()
         throws IOException

Specified by:

read in class InputStream

Throws:

IOException

skip

public long skip(long n)
          throws IOException

Overrides:

skip in class InputStream

Throws:

IOException

markSupported

public boolean markSupported()

Overrides:

markSupported in class InputStream

See Also:

InputStream.markSupported()

getWrappedInputStream

protected InputStream getWrappedInputStream()

Description copied from class: SdkInputStream

Returns the underlying input stream, if any, from the subclass; or null if there is no underlying input stream.

Specified by:

getWrappedInputStream in class SdkInputStream