Package akka.http.impl.engine.ws

Class WebSocketClientBlueprint

  • public class WebSocketClientBlueprint
extends java.lang.Object
    INTERNAL API

    • Method Summary

      All Methods Static Methods Concrete Methods 
      Modifier and Type Method Description
      static akka.stream.scaladsl.BidiFlow<Message,​akka.stream.TLSProtocol.SslTlsOutbound,​akka.stream.TLSProtocol.SslTlsInbound,​Message,​scala.concurrent.Future<WebSocketUpgradeResponse>> apply​(WebSocketRequest request, ClientConnectionSettings settings, akka.event.LoggingAdapter log)
      Returns a WebSocketClientLayer that can be materialized once.
      static akka.stream.scaladsl.BidiFlow<akka.util.ByteString,​akka.util.ByteString,​akka.util.ByteString,​akka.util.ByteString,​scala.concurrent.Future<WebSocketUpgradeResponse>> handshake​(WebSocketRequest request, ClientConnectionSettings settings, akka.event.LoggingAdapter log)
      A bidi flow that injects and inspects the WS handshake and then goes out of the way.
      static akka.stream.scaladsl.BidiFlow<akka.stream.TLSProtocol.SslTlsInbound,​akka.util.ByteString,​akka.util.ByteString,​akka.stream.TLSProtocol.SendBytes,​akka.NotUsed> simpleTls()  

      • Methods inherited from class java.lang.Object

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

    • Constructor Detail

      • WebSocketClientBlueprint

        public WebSocketClientBlueprint()

    • Method Detail

      • apply

        public static akka.stream.scaladsl.BidiFlow<Message,​akka.stream.TLSProtocol.SslTlsOutbound,​akka.stream.TLSProtocol.SslTlsInbound,​Message,​scala.concurrent.Future<WebSocketUpgradeResponse>> apply​(WebSocketRequest request,
                                                                                                                                                                                                                          ClientConnectionSettings settings,
                                                                                                                                                                                                                          akka.event.LoggingAdapter log)
        Returns a WebSocketClientLayer that can be materialized once.
        Parameters:
        request - (undocumented)
        settings - (undocumented)
        log - (undocumented)
        Returns:
        (undocumented)

      • handshake

        public static akka.stream.scaladsl.BidiFlow<akka.util.ByteString,​akka.util.ByteString,​akka.util.ByteString,​akka.util.ByteString,​scala.concurrent.Future<WebSocketUpgradeResponse>> handshake​(WebSocketRequest request,
                                                                                                                                                                                                                     ClientConnectionSettings settings,
                                                                                                                                                                                                                     akka.event.LoggingAdapter log)
        A bidi flow that injects and inspects the WS handshake and then goes out of the way. This BidiFlow can only be materialized once.
        Parameters:
        request - (undocumented)
        settings - (undocumented)
        log - (undocumented)
        Returns:
        (undocumented)

      • simpleTls

        public static akka.stream.scaladsl.BidiFlow<akka.stream.TLSProtocol.SslTlsInbound,​akka.util.ByteString,​akka.util.ByteString,​akka.stream.TLSProtocol.SendBytes,​akka.NotUsed> simpleTls()