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.
Definition at line 33 of file PollingInputStream.java.
Constructor & Destructor Documentation
| org.ros.android.acm_serial.PollingInputStream.PollingInputStream | ( | final InputStream | inputStream, |
| ExecutorService | executorService | ||
| ) | [inline] |
- Parameters:
-
inputStream the InputStream to read from executorService used to execute the read loop
Definition at line 52 of file PollingInputStream.java.
Member Function Documentation
| int org.ros.android.acm_serial.PollingInputStream.available | ( | ) | throws IOException [inline] |
Definition at line 114 of file PollingInputStream.java.
| synchronized int org.ros.android.acm_serial.PollingInputStream.read | ( | byte[] | buffer, |
| int | offset, | ||
| int | length | ||
| ) | throws IOException [inline] |
Definition at line 91 of file PollingInputStream.java.
| int org.ros.android.acm_serial.PollingInputStream.read | ( | ) | throws IOException [inline] |
Definition at line 108 of file PollingInputStream.java.
| int org.ros.android.acm_serial.PollingInputStream.remaining | ( | ) | [inline, private] |
Definition at line 118 of file PollingInputStream.java.
Member Data Documentation
final int org.ros.android.acm_serial.PollingInputStream.BUFFER_CAPACITY = 512 * 1024 [static, private] |
Definition at line 38 of file PollingInputStream.java.
final boolean org.ros.android.acm_serial.PollingInputStream.DEBUG = false [static, private] |
Definition at line 35 of file PollingInputStream.java.
final Log org.ros.android.acm_serial.PollingInputStream.log = LogFactory.getLog(PollingInputStream.class) [static, private] |
Definition at line 36 of file PollingInputStream.java.
final int org.ros.android.acm_serial.PollingInputStream.READ_SIZE = 256 [static, private] |
Definition at line 39 of file PollingInputStream.java.
final byte [] org.ros.android.acm_serial.PollingInputStream.readBuffer [private] |
Definition at line 41 of file PollingInputStream.java.
Definition at line 43 of file PollingInputStream.java.
Definition at line 44 of file PollingInputStream.java.
The documentation for this class was generated from the following file: