object GatewayHandlerGraphStage

Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. GatewayHandlerGraphStage
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Value Members

  1. def createMessage(implicit system: ActorSystem[Nothing]): Flow[GatewayMessage[_], Message, NotUsed]

    Turn a GatewayMessage into a websocket akka.http.scaladsl.model.ws.Message.

  2. def flow(wsUri: Uri, settings: GatewaySettings, prevResume: Option[ResumeData])(implicit system: ActorSystem[Nothing]): Flow[GatewayMessage[_], GatewayMessage[_], (Future[WebSocketUpgradeResponse], Future[(Option[ResumeData], Boolean)], Future[Unit])]
  3. def parseMessage(compress: Compress, eventDecoders: EventDecoders, shardInfo: ShardInfo)(implicit system: ActorSystem[Nothing]): Flow[Message, Either[Error, GatewayMessage[_]], NotUsed]

    Turn a websocket akka.http.scaladsl.model.ws.Message into a GatewayMessage.