org.apache.reef.io.network

Interface Connection<T>

Type Parameters:

T - type

All Superinterfaces:

AutoCloseable

public interface Connection<T>
extends AutoCloseable

Connection between two end-points named by identifiers.

Method Summary

Methods

Modifier and Type	Method and Description
void	close() Closes the connection.
void	open() Opens the connection.
void	write(List<T> messages) Writes a list of messages to the connection.
void	write(T message) Writes a message to the connection.

Method Detail

open

void open()
          throws NetworkException

Opens the connection.

Throws:

NetworkException

write

void write(T message)

Writes a message to the connection.

Parameters:

message -

write

void write(List<T> messages)

Writes a list of messages to the connection.

Parameters:

messages -

close

void close()
           throws NetworkException

Closes the connection.

Specified by:

close in interface AutoCloseable

Throws:

NetworkException