Package com.oracle.bmc.objectstorage.transfer.internal

Class StreamChunkCreator.DuplicatedSubRangeInputStream

java.lang.Object

java.io.InputStream

com.oracle.bmc.objectstorage.transfer.internal.StreamChunkCreator.SubRangeInputStream

com.oracle.bmc.objectstorage.transfer.internal.StreamChunkCreator.DuplicatedSubRangeInputStream

All Implemented Interfaces:

DuplicatableInputStream, Closeable, AutoCloseable

Enclosing class:

StreamChunkCreator

public static class StreamChunkCreator.DuplicatedSubRangeInputStream
extends StreamChunkCreator.SubRangeInputStream
implements DuplicatableInputStream

Creates a new duplicated SubRangeInputStream.

This individual sub range can be duplicated multiple times (ex, for retries).

This class should be used in place of StreamChunkCreator.SubRangeInputStream directly when the underlying input stream itself is a DuplicatableInputStream. This class will always duplicate the underlying stream while maintaining the desired start and end positions.

Because this stream can be duplicated for each thread, it will support InputStream.mark(int) and InputStream.reset() whenever the source stream does so, because only one thread will reset it, and the threads will not interfere with each other.

Field Summary

Fields inherited from class com.oracle.bmc.objectstorage.transfer.internal.StreamChunkCreator.SubRangeInputStream

currentStartPositionInSource, source

Constructor Summary

Constructors

Constructor	Description
DuplicatedSubRangeInputStream(DuplicatableInputStream source, long desiredStartPositionInSource, long desiredEndPositionInSource)

Method Summary

Modifier and Type	Method	Description
InputStream	duplicate()
void	mark(int readlimit)
boolean	markSupported()
void	reset()

Methods inherited from class com.oracle.bmc.objectstorage.transfer.internal.StreamChunkCreator.SubRangeInputStream

available, close, length, read, read

Methods inherited from class java.io.InputStream

nullInputStream, read, readAllBytes, readNBytes, readNBytes, skip, transferTo

Methods inherited from class java.lang.Object

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

Constructor Detail

DuplicatedSubRangeInputStream

public DuplicatedSubRangeInputStream(DuplicatableInputStream source,
                                     long desiredStartPositionInSource,
                                     long desiredEndPositionInSource)

Method Detail

markSupported

public boolean markSupported()

Overrides:

markSupported in class InputStream

mark

public void mark(int readlimit)

Overrides:

mark in class InputStream

reset

public void reset()
           throws IOException

Overrides:

reset in class InputStream

Throws:

IOException

duplicate

public InputStream duplicate()

Specified by:

duplicate in interface DuplicatableInputStream