io.micronaut.websocket

Interface RxWebSocketSession

All Superinterfaces:

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

All Known Implementing Classes:

NettyRxWebSocketSession

public interface RxWebSocketSession
extends WebSocketSession

Generalization of the WebSocketSession interface for RxJava.

Since:

1.0

Author:

graemerocher

Field Summary

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

EMPTY

Method Summary

Modifier and Type	Method and Description
java.util.Set<? extends RxWebSocketSession>	getOpenSessions() The current open sessions.
<T> io.reactivex.Flowable<T>	send(T message, MediaType mediaType) Broadcast a message and return a Flowable.

Methods inherited from interface io.micronaut.websocket.WebSocketSession

close, close, getAttributes, getId, getProtocolVersion, getRequestParameters, getRequestURI, getSubprotocol, getUriVariables, getUserPrincipal, isOpen, isSecure, isWritable, send, sendAsync, sendAsync, sendSync, sendSync

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

clear, of, put, putAll, putAll, remove

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

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

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

get, get, get, get

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Method Detail

getOpenSessions

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

The current open sessions.

Specified by:

getOpenSessions in interface WebSocketSession

Returns:

The open sessions

See Also:

WebSocketSession.getOpenSessions()

send

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

Broadcast a message and return a Flowable.

Specified by:

send in interface WebSocketSession

Type Parameters:

T - The message generic type

Parameters:

message - The message

mediaType - The media type

Returns:

The Flowable