Public Member Functions | Private Member Functions | Private Attributes | Static Private Attributes Class Reference
Inheritance diagram for
Inheritance graph

List of all members.

Public Member Functions

int available () throws IOException
 PollingInputStream (final InputStream inputStream, ExecutorService executorService)
synchronized int read (byte[] buffer, int offset, int length) throws IOException
int read () throws IOException

Private Member Functions

int remaining ()

Private Attributes

final byte[] readBuffer
int readPosition
int writePosition

Static Private Attributes

static final int BUFFER_CAPACITY = 512 * 1024
static final boolean DEBUG = false
static final Log log = LogFactory.getLog(PollingInputStream.class)
static final int READ_SIZE = 256

Detailed Description

Constantly reads from an InputStream into a buffer.

Author: (Damon Kohler)

Definition at line 33 of file

Constructor & Destructor Documentation ( final InputStream  inputStream,
ExecutorService  executorService 
) [inline]
inputStreamthe InputStream to read from
executorServiceused to execute the read loop

Definition at line 52 of file

Member Function Documentation

int ( ) throws IOException [inline]

Definition at line 114 of file

synchronized int ( byte[]  buffer,
int  offset,
int  length 
) throws IOException [inline]

Definition at line 91 of file

int ( ) throws IOException [inline]

Definition at line 108 of file

Definition at line 118 of file

Member Data Documentation

final int = 512 * 1024 [static, private]

Definition at line 38 of file

final boolean = false [static, private]

Definition at line 35 of file

final Log = LogFactory.getLog(PollingInputStream.class) [static, private]

Definition at line 36 of file

Definition at line 39 of file

Definition at line 41 of file

Definition at line 43 of file

Definition at line 44 of file

The documentation for this class was generated from the following file:

Author(s): Damon Kohler
autogenerated on Thu Jun 6 2019 21:20:07