Performs low level network IO operations between hosts More...

Public Member Functions
	Channel (NetworkStream stream)
	Constructs a new Channel with the the connected NetworkStream. More...

void	Write (byte[] message)
	Sends a message to the connected client synchronously More...

async Task	WriteAsync (byte[] message, CancellationToken token)
	Sends a message to the connected client asynchronously More...

byte[]	Read ()
	Reads an incoming message as a byte array synchronously. More...

async Task< byte[]>	ReadAsync (CancellationToken token)
	Reads an incoming message as a byte array asynchronously. More...

Detailed Description

Performs low level network IO operations between hosts

Constructor & Destructor Documentation

Org.Apache.REEF.Wake.Remote.Impl.Channel.Channel ( NetworkStream stream )

inline

Constructs a new Channel with the the connected NetworkStream.

Parameters

stream The connected stream

byte [] Org.Apache.REEF.Wake.Remote.Impl.Channel.Read ( )

inline

Reads an incoming message as a byte array synchronously.

The message length is read as the first four bytes.

async Task<byte[]> Org.Apache.REEF.Wake.Remote.Impl.Channel.ReadAsync ( CancellationToken token )

inline

Reads an incoming message as a byte array asynchronously.

The message length is read as the first four bytes.

Parameters

token The cancellation token

void Org.Apache.REEF.Wake.Remote.Impl.Channel.Write ( byte[] message )

inline

Sends a message to the connected client synchronously

Parameters

message The message to send

async Task Org.Apache.REEF.Wake.Remote.Impl.Channel.WriteAsync	(	byte[]	message,
		CancellationToken	token
	)

inline

Sends a message to the connected client asynchronously

Parameters

message	The message to send
token	The cancellation token

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