Apache REEF
0.15.0
Retainable Evaluator Execution Framework
|
Class with functions to Read from stream More...
Inherits Org.Apache.REEF.Wake.Remote.IDataReader.
Public Member Functions | |
StreamDataReader (Stream stream) | |
Constructs the StreamDataReader More... | |
double | ReadDouble () |
Reads double More... | |
float | ReadFloat () |
Reads float More... | |
long | ReadLong () |
Reads long More... | |
bool | ReadBoolean () |
Reads bool More... | |
int | ReadInt32 () |
Reads integer More... | |
short | ReadInt16 () |
Reads short More... | |
string | ReadString () |
Reads string More... | |
int | Read (ref byte[] buffer, int index, int bytesToRead) |
Reads data in to the buffer More... | |
async Task< double > | ReadDoubleAsync (CancellationToken token) |
Reads double asynchronously More... | |
async Task< float > | ReadFloatAsync (CancellationToken token) |
Reads float asynchronously More... | |
async Task< long > | ReadLongAsync (CancellationToken token) |
Reads long asynchronously More... | |
async Task< bool > | ReadBooleanAsync (CancellationToken token) |
Reads bool asynchronously More... | |
async Task< int > | ReadInt32Async (CancellationToken token) |
Reads integer asynchronously More... | |
async Task< short > | ReadInt16Async (CancellationToken token) |
Reads short asynchronously More... | |
async Task< string > | ReadStringAsync (CancellationToken token) |
Reads string asynchronously More... | |
async Task< int > | ReadAsync (byte[] buffer, int index, int bytesToRead, CancellationToken token) |
Reads data in to the buffer asynchronously More... | |
Class with functions to Read from stream
|
inline |
Constructs the StreamDataReader
stream | Stream from which to read |
|
inline |
Reads data in to the buffer
buffer | byte array to which to write |
index | starting index in the array |
bytesToRead | number of bytes to write |
Implements Org.Apache.REEF.Wake.Remote.IDataReader.
|
inline |
Reads data in to the buffer asynchronously
buffer | byte array to which to write |
index | starting index in the array |
bytesToRead | number of bytes to write |
token | Cancellation token |
Implements Org.Apache.REEF.Wake.Remote.IDataReader.
|
inline |
|
inline |
Reads bool asynchronously
token | Cancellation token |
Implements Org.Apache.REEF.Wake.Remote.IDataReader.
|
inline |
|
inline |
Reads double asynchronously
token | Cancellation token |
Implements Org.Apache.REEF.Wake.Remote.IDataReader.
|
inline |
|
inline |
Reads float asynchronously
token | Cancellation token |
Implements Org.Apache.REEF.Wake.Remote.IDataReader.
|
inline |
|
inline |
Reads short asynchronously
token | Cancellation token |
Implements Org.Apache.REEF.Wake.Remote.IDataReader.
|
inline |
|
inline |
Reads integer asynchronously
token | Cancellation token |
Implements Org.Apache.REEF.Wake.Remote.IDataReader.
|
inline |
|
inline |
Reads long asynchronously
token | Cancellation token |
Implements Org.Apache.REEF.Wake.Remote.IDataReader.
|
inline |
|
inline |
Reads string asynchronously
token | Cancellation token |
Implements Org.Apache.REEF.Wake.Remote.IDataReader.