Inherits Org.Apache.REEF.Wake.Remote.IDataWriter.

Public Member Functions
	StreamDataWriter (Stream stream)
	Constructs the StreamDataReader More...

void	WriteDouble (double obj)
	write double More...

void	WriteFloat (float obj)
	write float More...

void	WriteLong (long obj)
	write long More...

void	WriteBoolean (bool obj)
	write boolean More...

void	WriteInt32 (int obj)
	write integer More...

void	WriteInt16 (short obj)
	write short More...

void	WriteString (string obj)
	write string More...

void	Write (byte[] buffer, int index, int count)
	write bytes to the byte array More...

async Task	WriteDoubleAsync (double obj, CancellationToken token)
	write double asynchronously More...

async Task	WriteFloatAsync (float obj, CancellationToken token)
	write float asynchronously More...

async Task	WriteLongAsync (long obj, CancellationToken token)
	write long asynchronously More...

async Task	WriteBooleanAsync (bool obj, CancellationToken token)
	write bool asynchronously More...

async Task	WriteInt32Async (int obj, CancellationToken token)
	write integer asynchronously More...

async Task	WriteInt16Async (short obj, CancellationToken token)
	write short asynchronously More...

async Task	WriteStringAsync (string obj, CancellationToken token)
	write string asynchronously More...

async Task	WriteAsync (byte[] buffer, int index, int count, CancellationToken token)
	write bytes to the byte array asynchronously More...

Constructor & Destructor Documentation

Org.Apache.REEF.Wake.Remote.Impl.StreamDataWriter.StreamDataWriter ( Stream stream )

inline

Constructs the StreamDataReader

Parameters

stream Stream from which to read

Member Function Documentation

void Org.Apache.REEF.Wake.Remote.Impl.StreamDataWriter.Write	(	byte[]	buffer,
		int	index,
		int	count
	)

inline

write bytes to the byte array

Parameters

buffer	byte array from which to read
index	starting index in the array
count	number of bytes to write

Implements Org.Apache.REEF.Wake.Remote.IDataWriter.

async Task Org.Apache.REEF.Wake.Remote.Impl.StreamDataWriter.WriteAsync	(	byte[]	buffer,
		int	index,
		int	count,
		CancellationToken	token
	)

inline

write bytes to the byte array asynchronously

Parameters

buffer	byte array from which to read
index	starting index in the array
count	number of bytes to write
token	Cancellation token

Returns: the handler to the task

Implements Org.Apache.REEF.Wake.Remote.IDataWriter.

void Org.Apache.REEF.Wake.Remote.Impl.StreamDataWriter.WriteBoolean ( bool obj )

inline

write boolean

Parameters

obj	bool to be written

Implements Org.Apache.REEF.Wake.Remote.IDataWriter.

async Task Org.Apache.REEF.Wake.Remote.Impl.StreamDataWriter.WriteBooleanAsync	(	bool	obj,
		CancellationToken	token
	)

inline

write bool asynchronously

Parameters

obj	bool to be written
token	Cancellation token

Returns: the handler to the task

Implements Org.Apache.REEF.Wake.Remote.IDataWriter.

void Org.Apache.REEF.Wake.Remote.Impl.StreamDataWriter.WriteDouble ( double obj )

inline

write double

Parameters

obj	double to be written

Implements Org.Apache.REEF.Wake.Remote.IDataWriter.

async Task Org.Apache.REEF.Wake.Remote.Impl.StreamDataWriter.WriteDoubleAsync	(	double	obj,
		CancellationToken	token
	)

inline

write double asynchronously

Parameters

obj	double to be written
token	Cancellation token

Returns: the handler to the task

Implements Org.Apache.REEF.Wake.Remote.IDataWriter.

void Org.Apache.REEF.Wake.Remote.Impl.StreamDataWriter.WriteFloat ( float obj )

inline

write float

Parameters

obj	float to be written

Implements Org.Apache.REEF.Wake.Remote.IDataWriter.

async Task Org.Apache.REEF.Wake.Remote.Impl.StreamDataWriter.WriteFloatAsync	(	float	obj,
		CancellationToken	token
	)

inline

write float asynchronously

Parameters

obj	float to be written
token	Cancellation token

Returns: the handler to the task

Implements Org.Apache.REEF.Wake.Remote.IDataWriter.

void Org.Apache.REEF.Wake.Remote.Impl.StreamDataWriter.WriteInt16 ( short obj )

inline

write short

Parameters

obj	short to be written

Implements Org.Apache.REEF.Wake.Remote.IDataWriter.

async Task Org.Apache.REEF.Wake.Remote.Impl.StreamDataWriter.WriteInt16Async	(	short	obj,
		CancellationToken	token
	)

inline

write short asynchronously

Parameters

obj	short to be written
token	Cancellation token

Returns: the handler to the task

Implements Org.Apache.REEF.Wake.Remote.IDataWriter.

void Org.Apache.REEF.Wake.Remote.Impl.StreamDataWriter.WriteInt32 ( int obj )

inline

write integer

Parameters

obj	int to be written

Implements Org.Apache.REEF.Wake.Remote.IDataWriter.

async Task Org.Apache.REEF.Wake.Remote.Impl.StreamDataWriter.WriteInt32Async	(	int	obj,
		CancellationToken	token
	)

inline

write integer asynchronously

Parameters

obj	integer to be written
token	Cancellation token

Returns: the handler to the task

Implements Org.Apache.REEF.Wake.Remote.IDataWriter.

void Org.Apache.REEF.Wake.Remote.Impl.StreamDataWriter.WriteLong ( long obj )

inline

write long

Parameters

obj	long to be written

Implements Org.Apache.REEF.Wake.Remote.IDataWriter.

async Task Org.Apache.REEF.Wake.Remote.Impl.StreamDataWriter.WriteLongAsync	(	long	obj,
		CancellationToken	token
	)

inline

write long asynchronously

Parameters

obj	long to be written
token	Cancellation token

Returns: the handler to the task

Implements Org.Apache.REEF.Wake.Remote.IDataWriter.

void Org.Apache.REEF.Wake.Remote.Impl.StreamDataWriter.WriteString ( string obj )

inline

write string

Parameters

obj	string to be written

Implements Org.Apache.REEF.Wake.Remote.IDataWriter.

async Task Org.Apache.REEF.Wake.Remote.Impl.StreamDataWriter.WriteStringAsync	(	string	obj,
		CancellationToken	token
	)

inline

write string asynchronously

Parameters

obj	string to be written
token	Cancellation token

Returns: the handler to the task

Implements Org.Apache.REEF.Wake.Remote.IDataWriter.

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

lang/cs/Org.Apache.REEF.Wake/Remote/Impl/StreamDataWriter.cs

Public Member Functions

Constructor & Destructor Documentation

Member Function Documentation