This project has retired. For details please refer to its Attic page.
Apache REEF: Org.Apache.REEF.Wake.StreamingCodec.CodecToStreamingCodec< T > Class Template Reference
Apache REEF  0.15.0
Retainable Evaluator Execution Framework
Public Member Functions | List of all members
Org.Apache.REEF.Wake.StreamingCodec.CodecToStreamingCodec< T > Class Template Reference

Converts codec to streaming codec More...

Inherits Org.Apache.REEF.Wake.StreamingCodec.IStreamingCodec< T >.

Public Member Functions

Read (IDataReader reader)
 Instantiate the class from the reader. More...
 
void Write (T obj, IDataWriter writer)
 Writes the class fields to the writer. More...
 
async Task< T > ReadAsync (IDataReader reader, CancellationToken token)
 Instantiate the class from the reader. More...
 
async Task WriteAsync (T obj, IDataWriter writer, CancellationToken token)
 Writes the class fields to the writer. More...
 

Detailed Description

Converts codec to streaming codec

Template Parameters
TMessage type

Member Function Documentation

Instantiate the class from the reader.

Parameters
readerThe reader from which to read
Returns
The instance of type T read from the reader

Implements Org.Apache.REEF.Wake.StreamingCodec.IStreamingCodec< T >.

async Task<T> Org.Apache.REEF.Wake.StreamingCodec.CodecToStreamingCodec< T >.ReadAsync ( IDataReader  reader,
CancellationToken  token 
)
inline

Instantiate the class from the reader.

Parameters
readerThe reader from which to read
tokenCancellation token
Returns
The instance of type T read from the reader

Implements Org.Apache.REEF.Wake.StreamingCodec.IStreamingCodec< T >.

void Org.Apache.REEF.Wake.StreamingCodec.CodecToStreamingCodec< T >.Write ( obj,
IDataWriter  writer 
)
inline

Writes the class fields to the writer.

Parameters
objThe object of type T to be encoded
writerThe writer to which to write

Implements Org.Apache.REEF.Wake.StreamingCodec.IStreamingCodec< T >.

async Task Org.Apache.REEF.Wake.StreamingCodec.CodecToStreamingCodec< T >.WriteAsync ( obj,
IDataWriter  writer,
CancellationToken  token 
)
inline

Writes the class fields to the writer.

Parameters
objThe object of type T to be encoded
writerThe writer to which to write
tokenCancellation token

Implements Org.Apache.REEF.Wake.StreamingCodec.IStreamingCodec< T >.


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