io.cettia.transport

Interface ServerTransport

All Known Implementing Classes:

BaseServerTransport

public interface ServerTransport

Represents a server-side full duplex message channel ensuring there is no message loss and no idle connection.

Implementations are thread safe.

Author:

Donghwan Kim

Method Summary

Methods

Modifier and Type	Method and Description
void	close() Closes the connection.
ServerTransport	onbinary(Action<ByteBuffer> action) Attaches an action for the binary message.
ServerTransport	onclose(Action<Void> action) Attaches an action for the close event.
ServerTransport	onerror(Action<Throwable> action) Executed if there was any error on the connection.
ServerTransport	ontext(Action<String> action) Attaches an action for the text message.
ServerTransport	send(ByteBuffer data) Sends a binary message through the connection.
ServerTransport	send(String data) Sends a text message through the connection.
<T> T	unwrap(Class<T> clazz) Returns the underlying component.
String	uri() A URI used to connect.

Method Detail

uri

String uri()

A URI used to connect. To work with URI parts, use URI or something like that.

onerror

ServerTransport onerror(Action<Throwable> action)

Executed if there was any error on the connection. You don't need to close it explicitly.

ontext

ServerTransport ontext(Action<String> action)

Attaches an action for the text message.

onbinary

ServerTransport onbinary(Action<ByteBuffer> action)

Attaches an action for the binary message.

send

ServerTransport send(String data)

Sends a text message through the connection.

send

ServerTransport send(ByteBuffer data)

Sends a binary message through the connection.

onclose

ServerTransport onclose(Action<Void> action)

Attaches an action for the close event. After this event, the instance shouldn't be used and all the other events will be disabled.

close

void close()

Closes the connection. This method has no side effect if called more than once.

unwrap

<T> T unwrap(Class<T> clazz)

Returns the underlying component.