io.cettia.transport

Class BaseServerTransport

java.lang.Object

io.cettia.transport.BaseServerTransport

All Implemented Interfaces:

ServerTransport

public abstract class BaseServerTransport
extends Object
implements ServerTransport

Base class for ServerTransport.

Author:

Donghwan Kim

Field Summary

Fields

Modifier and Type	Field and Description
protected Actions<ByteBuffer>	binaryActions
protected Actions<Void>	closeActions
protected Actions<Throwable>	errorActions
protected Actions<String>	textActions

Constructor Summary

Constructors

Constructor and Description
BaseServerTransport()

Method Summary

Methods

Modifier and Type	Method and Description
void	close() Closes the connection.
protected abstract void	doClose()
protected abstract void	doSend(ByteBuffer data)
protected abstract void	doSend(String data)
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.
BaseServerTransport	send(String data) Sends a text message through the connection.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.cettia.transport.ServerTransport

unwrap, uri

Field Detail

textActions

protected Actions<String> textActions

binaryActions

protected Actions<ByteBuffer> binaryActions

errorActions

protected Actions<Throwable> errorActions

closeActions

protected Actions<Void> closeActions

Constructor Detail

BaseServerTransport

public BaseServerTransport()

Method Detail

ontext

public ServerTransport ontext(Action<String> action)

Description copied from interface: ServerTransport

Attaches an action for the text message.

Specified by:

ontext in interface ServerTransport

onbinary

public ServerTransport onbinary(Action<ByteBuffer> action)

Description copied from interface: ServerTransport

Attaches an action for the binary message.

Specified by:

onbinary in interface ServerTransport

send

public BaseServerTransport send(String data)

Description copied from interface: ServerTransport

Sends a text message through the connection.

Specified by:

send in interface ServerTransport

send

public ServerTransport send(ByteBuffer data)

Description copied from interface: ServerTransport

Sends a binary message through the connection.

Specified by:

send in interface ServerTransport

doSend

protected abstract void doSend(String data)

doSend

protected abstract void doSend(ByteBuffer data)

onerror

public ServerTransport onerror(Action<Throwable> action)

Description copied from interface: ServerTransport

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

Specified by:

onerror in interface ServerTransport

onclose

public ServerTransport onclose(Action<Void> action)

Description copied from interface: ServerTransport

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

Specified by:

onclose in interface ServerTransport

close

public void close()

Description copied from interface: ServerTransport

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

Specified by:

close in interface ServerTransport

doClose

protected abstract void doClose()