Dependencies
- com.github.spotbugs/spotbugs-annotations/4.0.3
- com.google.code.findbugs/jsr305/3.0.2
- io.micronaut/micronaut-aop/2.2.0
- io.micronaut/micronaut-core/2.2.0
- io.micronaut/micronaut-http/2.2.0
- io.micronaut/micronaut-inject/2.2.0
- io.reactivex.rxjava2/rxjava/2.2.10
- java/11
- javax.annotation/javax.annotation-api/1.3.2
- javax.inject/javax.inject/1
- org.reactivestreams/reactive-streams/1.0.2
- org.slf4j/slf4j-api/1.7.26
- org.yaml/snakeyaml/1.26
Declarations
-
io
-
micronaut
-
websocket
-
CloseReason
-
NORMAL: CloseReason
-
GOING_AWAY: CloseReason
-
PROTOCOL_ERROR: CloseReason
-
UNSUPPORTED_DATA: CloseReason
-
NO_STATUS_RECEIVED: CloseReason
-
ABNORMAL_CLOSURE: CloseReason
-
INVALID_FRAME_PAYLOAD_DATA: CloseReason
-
POLICY_VIOLATION: CloseReason
-
MESSAGE_TO_BIG: CloseReason
-
MISSING_EXTENSION: CloseReason
-
INTERNAL_ERROR: CloseReason
-
SERVICE_RESTART: CloseReason
-
TRY_AGAIN_LATER: CloseReason
-
BAD_GATEWAY: CloseReason
-
TLS_HANDSHAKE: CloseReason
-
code: int
-
reason: String
-
CloseReason(int, String): void
-
getCode(): int
-
getReason(): String
-
equals(Object): boolean
-
hashCode(): int
-
toString(): String
-
-
RxWebSocketClient
-
RxWebSocketSession
-
WebSocketBroadcaster
-
broadcast(Object, MediaType, Predicate<WebSocketSession>): Publisher<Object>
-
broadcast(Object, MediaType): Publisher<Object>
-
broadcast(Object): Publisher<Object>
-
broadcast(Object, Predicate<WebSocketSession>): Publisher<Object>
-
broadcastAsync(Object, MediaType, Predicate<WebSocketSession>): CompletableFuture<Object>
-
broadcastAsync(Object): CompletableFuture<Object>
-
broadcastAsync(Object, Predicate<WebSocketSession>): CompletableFuture<Object>
-
broadcastAsync(Object, MediaType): CompletableFuture<Object>
-
broadcastSync(Object, MediaType, Predicate<WebSocketSession>): void
-
broadcastSync(Object): void
-
broadcastSync(Object, Predicate<WebSocketSession>): void
-
broadcastSync(Object, MediaType): void
-
-
WebSocketClient
-
SCHEME_WS: String
-
SCHEME_WSS: String
-
connect(Class<AutoCloseable>, MutableHttpRequest<Object>): Publisher<AutoCloseable>
-
connect(Class<AutoCloseable>, Map<String, Object>): Publisher<AutoCloseable>
-
close(): void
-
connect(Class<AutoCloseable>, String): Publisher<AutoCloseable>
-
connect(Class<AutoCloseable>, URI): Publisher<AutoCloseable>
-
-
WebSocketSession
-
getId(): String
-
getAttributes(): MutableConvertibleValues<Object>
-
isOpen(): boolean
-
isWritable(): boolean
-
isSecure(): boolean
-
getOpenSessions(): Set<WebSocketSession>
-
getRequestURI(): URI
-
getProtocolVersion(): String
-
send(Object, MediaType): Publisher<Object>
-
sendAsync(Object, MediaType): CompletableFuture<Object>
-
sendSync(Object, MediaType): void
-
send(Object): Publisher<Object>
-
sendAsync(Object): CompletableFuture<Object>
-
sendSync(Object): void
-
getSubprotocol(): Optional<String>
-
getRequestParameters(): ConvertibleMultiValues<String>
-
getUriVariables(): ConvertibleValues<Object>
-
getUserPrincipal(): Optional<Principal>
-
close(): void
-
close(CloseReason): void
-
-
WebSocketVersion
-
annotation
-
bind
-
WebSocketState
-
WebSocketStateBinder
-
WebSocketStateBinderRegistry
-
requestBinderRegistry: ArgumentBinderRegistry<HttpRequest<Object>>
-
byType: Map<Class, ArgumentBinder<Object, WebSocketState>>
-
queryValueArgumentBinder: ArgumentBinder<Object, HttpRequest<Object>>
-
WebSocketStateBinderRegistry(RequestBinderRegistry): void
-
addRequestArgumentBinder(ArgumentBinder<Object, Object>): void
-
findArgumentBinder(Argument<Object>, WebSocketState): Optional<ArgumentBinder<Object, WebSocketState>>
-
-
-
context
-
DefaultWebSocketBeanRegistry
-
beanContext: BeanContext
-
stereotype: Class<Annotation>
-
webSocketBeanMap: Map<Class, WebSocketBean>
-
DefaultWebSocketBeanRegistry(BeanContext, Class<Annotation>): void
-
getWebSocket(Class<Object>): WebSocketBean<Object>
-
DefaultWebSocketBean
-
bean: Object
-
definition: BeanDefinition<Object>
-
onOpen: MethodExecutionHandle<Object, Object>
-
onClose: MethodExecutionHandle<Object, Object>
-
onMessage: MethodExecutionHandle<Object, Object>
-
onError: MethodExecutionHandle<Object, Object>
-
DefaultWebSocketBean(Object, BeanDefinition<Object>, MethodExecutionHandle<Object, Object>, MethodExecutionHandle<Object, Object>, MethodExecutionHandle<Object, Object>, MethodExecutionHandle<Object, Object>): void
-
getBeanDefinition(): BeanDefinition<Object>
-
getTarget(): Object
-
messageMethod(): Optional<MethodExecutionHandle<Object, Object>>
-
closeMethod(): Optional<MethodExecutionHandle<Object, Object>>
-
openMethod(): Optional<MethodExecutionHandle<Object, Object>>
-
errorMethod(): Optional<MethodExecutionHandle<Object, Object>>
-
-
-
WebSocketBean
-
getBeanDefinition(): BeanDefinition<Object>
-
getTarget(): Object
-
messageMethod(): Optional<MethodExecutionHandle<Object, Object>>
-
closeMethod(): Optional<MethodExecutionHandle<Object, Object>>
-
openMethod(): Optional<MethodExecutionHandle<Object, Object>>
-
errorMethod(): Optional<MethodExecutionHandle<Object, Object>>
-
-
WebSocketBeanRegistry
-
-
event
-
exceptions
-
interceptor
-
-
-
Java files
io/micronaut/websocket/
Class files