io.micronaut.http.netty.websocket

Class NettyServerWebSocketBroadcaster

java.lang.Object

io.micronaut.http.netty.websocket.NettyServerWebSocketBroadcaster

All Implemented Interfaces:

WebSocketBroadcaster

@Singleton
 @Requires(beans=WebSocketSessionRepository.class)
public class NettyServerWebSocketBroadcaster
extends java.lang.Object
implements WebSocketBroadcaster

Netty implementation of WebSocketBroadcaster.

Since:

1.0

Author:

sdelamo

Constructor Summary

Constructors

Constructor and Description
NettyServerWebSocketBroadcaster(WebSocketMessageEncoder webSocketMessageEncoder, WebSocketSessionRepository webSocketSessionRepository)

Method Summary

Modifier and Type	Method and Description
<T> io.reactivex.Flowable<T>	broadcast(T message, MediaType mediaType, java.util.function.Predicate<WebSocketSession> filter) When used on the server this method will broadcast a message to all open WebSocket connections that match the given filter.
<T> void	broadcastSync(T message, MediaType mediaType, java.util.function.Predicate<WebSocketSession> filter) When used on the server this method will broadcast a message to all open WebSocket connections.

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.micronaut.websocket.WebSocketBroadcaster

broadcast, broadcast, broadcast, broadcastAsync, broadcastAsync, broadcastAsync, broadcastAsync, broadcastSync, broadcastSync, broadcastSync

Constructor Detail

NettyServerWebSocketBroadcaster

public NettyServerWebSocketBroadcaster(WebSocketMessageEncoder webSocketMessageEncoder,
                                       WebSocketSessionRepository webSocketSessionRepository)

Parameters:

webSocketMessageEncoder - A instance of WebSocketMessageEncoder responsible of encoding WebSocket messages.

webSocketSessionRepository - A instance of WebSocketSessionRepository. Defines a ChannelGroup repository to handle WebSockets.

Method Detail

broadcastSync

public <T> void broadcastSync(T message,
                              MediaType mediaType,
                              java.util.function.Predicate<WebSocketSession> filter)

Description copied from interface: WebSocketBroadcaster

When used on the server this method will broadcast a message to all open WebSocket connections.

Specified by:

broadcastSync in interface WebSocketBroadcaster

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.

filter - The filter

broadcast

public <T> io.reactivex.Flowable<T> broadcast(T message,
                                              MediaType mediaType,
                                              java.util.function.Predicate<WebSocketSession> filter)

Description copied from interface: WebSocketBroadcaster

When used on the server this method will broadcast a message to all open WebSocket connections that match the given filter. The resulting Publisher does not start sending until subscribed to. If you return it from Micronaut annotated methods such as OnOpen and OnMessage, Micronaut will subscribe to it and send the message without blocking.

Specified by:

broadcast in interface WebSocketBroadcaster

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.

filter - The filter to apply

Returns:

A Publisher that either emits an error or emits the message once it has been published successfully.