akka.http.impl.engine.ws

Class WebSocket

java.lang.Object

akka.http.impl.engine.ws.WebSocket

public class WebSocket
extends java.lang.Object

INTERNAL API

Defines components of the websocket stack.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	WebSocket.Tick$

Constructor Summary

Constructors

Constructor and Description
WebSocket()

Method Summary

Modifier and Type	Method and Description
static akka.stream.scaladsl.BidiFlow<FrameEventOrError,FrameHandler.Output,java.lang.Object,FrameStart,akka.NotUsed>	frameHandling(boolean serverSide, scala.concurrent.duration.FiniteDuration closeTimeout, akka.event.LoggingAdapter log) The layer that implements all low-level frame handling, like handling control frames, collecting messages from frames, decoding text messages, close handling, etc.
static akka.stream.scaladsl.BidiFlow<akka.util.ByteString,FrameEvent,FrameEvent,akka.util.ByteString,akka.NotUsed>	framing() The lowest layer that implements the binary protocol
static akka.stream.scaladsl.BidiFlow<FrameEvent,FrameEventOrError,FrameEvent,FrameEvent,akka.NotUsed>	masking(boolean serverSide, scala.Function0<java.util.Random> maskingRandomFactory) The layer that handles masking using the rules defined in the specification
static akka.stream.scaladsl.BidiFlow<FrameHandler.Output,Message,Message,java.lang.Object,akka.NotUsed>	messageAPI(boolean serverSide, scala.concurrent.duration.FiniteDuration closeTimeout) The layer that provides the high-level user facing API on top of frame handling.
static akka.stream.scaladsl.BidiFlow<FrameEvent,Message,Message,FrameEvent,akka.NotUsed>	stack(boolean serverSide, scala.Function0<java.util.Random> maskingRandomFactory, scala.concurrent.duration.FiniteDuration closeTimeout, akka.event.LoggingAdapter log) A stack of all the higher WS layers between raw frames and the user API.

Methods inherited from class java.lang.Object

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

Constructor Detail

WebSocket

public WebSocket()

Method Detail

stack

public static akka.stream.scaladsl.BidiFlow<FrameEvent,Message,Message,FrameEvent,akka.NotUsed> stack(boolean serverSide,
                                                                                                      scala.Function0<java.util.Random> maskingRandomFactory,
                                                                                                      scala.concurrent.duration.FiniteDuration closeTimeout,
                                                                                                      akka.event.LoggingAdapter log)

A stack of all the higher WS layers between raw frames and the user API.

Parameters:

serverSide - (undocumented)

maskingRandomFactory - (undocumented)

closeTimeout - (undocumented)

log - (undocumented)

Returns:

(undocumented)

framing

public static akka.stream.scaladsl.BidiFlow<akka.util.ByteString,FrameEvent,FrameEvent,akka.util.ByteString,akka.NotUsed> framing()

The lowest layer that implements the binary protocol

masking

public static akka.stream.scaladsl.BidiFlow<FrameEvent,FrameEventOrError,FrameEvent,FrameEvent,akka.NotUsed> masking(boolean serverSide,
                                                                                                                     scala.Function0<java.util.Random> maskingRandomFactory)

The layer that handles masking using the rules defined in the specification

frameHandling

public static akka.stream.scaladsl.BidiFlow<FrameEventOrError,FrameHandler.Output,java.lang.Object,FrameStart,akka.NotUsed> frameHandling(boolean serverSide,
                                                                                                                                          scala.concurrent.duration.FiniteDuration closeTimeout,
                                                                                                                                          akka.event.LoggingAdapter log)

The layer that implements all low-level frame handling, like handling control frames, collecting messages from frames, decoding text messages, close handling, etc.

Parameters:

serverSide - (undocumented)

closeTimeout - (undocumented)

log - (undocumented)

Returns:

(undocumented)

messageAPI

public static akka.stream.scaladsl.BidiFlow<FrameHandler.Output,Message,Message,java.lang.Object,akka.NotUsed> messageAPI(boolean serverSide,
                                                                                                                          scala.concurrent.duration.FiniteDuration closeTimeout)

The layer that provides the high-level user facing API on top of frame handling.

Parameters:

serverSide - (undocumented)

closeTimeout - (undocumented)

Returns:

(undocumented)