io.micronaut.http.netty.websocket

Class NettyRxWebSocketSession

java.lang.Object

io.micronaut.http.netty.websocket.NettyRxWebSocketSession

All Implemented Interfaces:

ConvertibleValues<java.lang.Object>, MutableConvertibleValues<java.lang.Object>, ValueResolver<java.lang.CharSequence>, RxWebSocketSession, WebSocketSession, java.lang.AutoCloseable, java.lang.Iterable<java.util.Map.Entry<java.lang.String,java.lang.Object>>

@Internal
public class NettyRxWebSocketSession
extends java.lang.Object
implements RxWebSocketSession

Implementation of the RxWebSocketSession interface for Netty and RxJava.

Since:

1.0

Author:

graemerocher

Field Summary

Fields

Modifier and Type	Field and Description
static io.netty.util.AttributeKey<NettyRxWebSocketSession>	WEB_SOCKET_SESSION_KEY The WebSocket session is stored within a Channel attribute using the given key.

Fields inherited from interface io.micronaut.core.convert.value.ConvertibleValues

EMPTY

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	NettyRxWebSocketSession(java.lang.String id, io.netty.channel.Channel channel, HttpRequest<?> request, MediaTypeCodecRegistry codecRegistry, java.lang.String protocolVersion, boolean isSecure) Creates a new netty web socket session.

Method Summary

Modifier and Type	Method and Description
MutableConvertibleValues<java.lang.Object>	clear() Clear all values.
void	close()
void	close(CloseReason closeReason) Close the session with the given event.
<T> java.util.Optional<T>	get(java.lang.CharSequence name, ArgumentConversionContext<T> conversionContext) Resolve the given property for the given name.
MutableConvertibleValues<java.lang.Object>	getAttributes()
java.lang.String	getId() The ID of the session.
java.util.Set<? extends RxWebSocketSession>	getOpenSessions() The current open sessions.
java.lang.String	getProtocolVersion() The protocol version of the WebSocket protocol currently being used.
ConvertibleMultiValues<java.lang.String>	getRequestParameters() The request parameters used to create this session.
java.net.URI	getRequestURI() The request URI this session was opened under.
boolean	isOpen() Whether the session is open.
boolean	isSecure() Whether the connection is secure.
boolean	isWritable() Whether the session is writable.
java.util.Set<java.lang.String>	names()
MutableConvertibleValues<java.lang.Object>	put(java.lang.CharSequence key, java.lang.Object value) Insert a value for the given key and value.
MutableConvertibleValues<java.lang.Object>	remove(java.lang.CharSequence key) Remove a value for the given key.
<T> io.reactivex.Flowable<T>	send(T message, MediaType mediaType) Broadcast a message and return a Flowable.
<T> java.util.concurrent.CompletableFuture<T>	sendAsync(T message, MediaType mediaType) Send the given message to the remote peer asynchronously.
void	sendSync(java.lang.Object message, MediaType mediaType) Send the given message to the remote peer synchronously.
java.lang.String	toString()
java.util.Collection<java.lang.Object>	values()

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.micronaut.websocket.WebSocketSession

getSubprotocol, getUriVariables, getUserPrincipal, send, sendAsync, sendSync

Methods inherited from interface io.micronaut.core.convert.value.MutableConvertibleValues

of, putAll, putAll

Methods inherited from interface io.micronaut.core.convert.value.ConvertibleValues

asMap, asMap, asProperties, contains, empty, forEach, getValue, getValueType, isEmpty, iterator, subMap, subMap, subMap

Methods inherited from interface io.micronaut.core.value.ValueResolver

get, get, get

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Field Detail

WEB_SOCKET_SESSION_KEY

public static final io.netty.util.AttributeKey<NettyRxWebSocketSession> WEB_SOCKET_SESSION_KEY

The WebSocket session is stored within a Channel attribute using the given key.

Constructor Detail

NettyRxWebSocketSession

protected NettyRxWebSocketSession(java.lang.String id,
                                  io.netty.channel.Channel channel,
                                  HttpRequest<?> request,
                                  MediaTypeCodecRegistry codecRegistry,
                                  java.lang.String protocolVersion,
                                  boolean isSecure)

Creates a new netty web socket session.

Parameters:

id - The ID

channel - The channel

request - The original request used to create the session

codecRegistry - The codec registry

protocolVersion - The protocol version

isSecure - Whether the session is secure

Method Detail

getId

public java.lang.String getId()

Description copied from interface: WebSocketSession

The ID of the session.

Specified by:

getId in interface WebSocketSession

Returns:

The ID of the session

getAttributes

public MutableConvertibleValues<java.lang.Object> getAttributes()

Specified by:

getAttributes in interface WebSocketSession

Returns:

Only the attributes of the session

isOpen

public boolean isOpen()

Description copied from interface: WebSocketSession

Whether the session is open.

Specified by:

isOpen in interface WebSocketSession

Returns:

True if it is

isWritable

public boolean isWritable()

Description copied from interface: WebSocketSession

Whether the session is writable. It may not be writable, if the buffer is currently full

Specified by:

isWritable in interface WebSocketSession

Returns:

True if it is

isSecure

public boolean isSecure()

Description copied from interface: WebSocketSession

Whether the connection is secure.

Specified by:

isSecure in interface WebSocketSession

Returns:

True if it is secure

getOpenSessions

public java.util.Set<? extends RxWebSocketSession> getOpenSessions()

Description copied from interface: RxWebSocketSession

The current open sessions.

Specified by:

getOpenSessions in interface RxWebSocketSession

Specified by:

getOpenSessions in interface WebSocketSession

Returns:

The open sessions

See Also:

WebSocketSession.getOpenSessions()

getRequestURI

public java.net.URI getRequestURI()

Description copied from interface: WebSocketSession

The request URI this session was opened under.

Specified by:

getRequestURI in interface WebSocketSession

Returns:

The request URI

getRequestParameters

public ConvertibleMultiValues<java.lang.String> getRequestParameters()

Description copied from interface: WebSocketSession

The request parameters used to create this session.

Specified by:

getRequestParameters in interface WebSocketSession

Returns:

The request parameters

getProtocolVersion

public java.lang.String getProtocolVersion()

Description copied from interface: WebSocketSession

The protocol version of the WebSocket protocol currently being used.

Specified by:

getProtocolVersion in interface WebSocketSession

Returns:

The protocol version

sendAsync

public <T> java.util.concurrent.CompletableFuture<T> sendAsync(T message,
                                                               MediaType mediaType)

Description copied from interface: WebSocketSession

Send the given message to the remote peer asynchronously.

Specified by:

sendAsync in interface WebSocketSession

Type Parameters:

T - The message type

Parameters:

message - The message

mediaType - The media type of the message. Used to lookup an appropriate codec via the MediaTypeCodecRegistry.

Returns:

A CompletableFuture that tracks the execution. CompletableFuture.get() and related methods will return the message on success, on error throw the underlying Exception.

sendSync

public void sendSync(java.lang.Object message,
                     MediaType mediaType)

Description copied from interface: WebSocketSession

Send the given message to the remote peer synchronously.

Specified by:

sendSync in interface WebSocketSession

Parameters:

message - The message

mediaType - The media type of the message. Used to lookup an appropriate codec via the MediaTypeCodecRegistry.

send

public <T> io.reactivex.Flowable<T> send(T message,
                                         MediaType mediaType)

Description copied from interface: RxWebSocketSession

Broadcast a message and return a Flowable.

Specified by:

send in interface RxWebSocketSession

Specified by:

send in interface WebSocketSession

Type Parameters:

T - The message generic type

Parameters:

message - The message

mediaType - The media type

Returns:

The Flowable

close

public void close()

Specified by:

close in interface WebSocketSession

Specified by:

close in interface java.lang.AutoCloseable

close

public void close(CloseReason closeReason)

Description copied from interface: WebSocketSession

Close the session with the given event.

Specified by:

close in interface WebSocketSession

Parameters:

closeReason - The close event

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

put

public MutableConvertibleValues<java.lang.Object> put(java.lang.CharSequence key,
                                                      @Nullable
                                                      java.lang.Object value)

Description copied from interface: MutableConvertibleValues

Insert a value for the given key and value.

Specified by:

put in interface MutableConvertibleValues<java.lang.Object>

Parameters:

key - The key

value - The value

Returns:

The previous value

remove

public MutableConvertibleValues<java.lang.Object> remove(java.lang.CharSequence key)

Description copied from interface: MutableConvertibleValues

Remove a value for the given key.

Specified by:

remove in interface MutableConvertibleValues<java.lang.Object>

Parameters:

key - The key

Returns:

The previous value

clear

public MutableConvertibleValues<java.lang.Object> clear()

Description copied from interface: MutableConvertibleValues

Clear all values.

Specified by:

clear in interface MutableConvertibleValues<java.lang.Object>

Returns:

This values instance

names

public java.util.Set<java.lang.String> names()

Specified by:

names in interface ConvertibleValues<java.lang.Object>

Returns:

The names of the values

values

public java.util.Collection<java.lang.Object> values()

Specified by:

values in interface ConvertibleValues<java.lang.Object>

Returns:

The values

get

public <T> java.util.Optional<T> get(java.lang.CharSequence name,
                                     ArgumentConversionContext<T> conversionContext)

Description copied from interface: ValueResolver

Resolve the given property for the given name.

Specified by:

get in interface ValueResolver<java.lang.CharSequence>

Type Parameters:

T - The concrete type

Parameters:

name - The name

conversionContext - The conversion context

Returns:

An optional containing the property value if it exists and is able to be converted