ddf.catalog.resource.download

Class ReliableResourceInputStream

java.lang.Object

java.io.InputStream

ddf.catalog.resource.download.ReliableResourceInputStream

All Implemented Interfaces:

Closeable, AutoCloseable

public class ReliableResourceInputStream
extends InputStream

The @InputStream used by the client to read from the @FileBackedOutputStream being written to as the resource is being downloaded.

Constructor Summary

Constructors

Constructor and Description
ReliableResourceInputStream(com.google.common.io.FileBackedOutputStream fbos, com.google.common.io.CountingOutputStream countingFbos, DownloadManagerState downloadState, String downloadIdentifier, ResourceResponse resourceResponse)

Method Summary

Modifier and Type	Method and Description
void	close()
long	getBytesCached()
long	getBytesRead() Returns the number of bytes read thus far from the @FileBackedOutputStream
DownloadManagerState	getDownloadState()
boolean	isClosed()
int	read()
int	read(byte[] b, int off, int len)
void	setCallableAndItsFuture(ReliableResourceCallable reliableResourceCallable, Future<ReliableResourceStatus> downloadFuture) Sets the @Callable and the @Future that started the @Callable that is populating the

Methods inherited from class java.io.InputStream

available, mark, markSupported, read, reset, skip

Methods inherited from class java.lang.Object

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

Constructor Detail

ReliableResourceInputStream

public ReliableResourceInputStream(com.google.common.io.FileBackedOutputStream fbos,
                                   com.google.common.io.CountingOutputStream countingFbos,
                                   DownloadManagerState downloadState,
                                   String downloadIdentifier,
                                   ResourceResponse resourceResponse)

Parameters:

fbos - the @FileBackedOutputStream this object will read from

countingFbos - wrapped @FileBackedOutputStream that counts the number of bytes written so far

downloadState - the current state of the resource's download

Method Detail

setCallableAndItsFuture

public void setCallableAndItsFuture(ReliableResourceCallable reliableResourceCallable,
                                    Future<ReliableResourceStatus> downloadFuture)

Sets the @Callable and the @Future that started the @Callable that is populating the

Parameters:

reliableResourceCallable -

cachingFuture - @FileBackedOutputStream is object is reading from.

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Overrides:

close in class InputStream

Throws:

IOException

isClosed

public boolean isClosed()

read

public int read()
         throws IOException

Specified by:

read in class InputStream

Throws:

IOException

read

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

Overrides:

read in class InputStream

Throws:

IOException

getBytesRead

public long getBytesRead()

Returns the number of bytes read thus far from the @FileBackedOutputStream

Returns:

getBytesCached

public long getBytesCached()

getDownloadState

public DownloadManagerState getDownloadState()