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()