Package org.apache.pekko.http.impl.engine.ws

Class WebSocketClientBlueprint$

java.lang.Object
org.apache.pekko.http.impl.engine.ws.WebSocketClientBlueprint$
public class WebSocketClientBlueprint$ extends Object
INTERNAL API

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    static final WebSocketClientBlueprint$
    MODULE$
    Static reference to the singleton instance of this Scala object.

  • Constructor Summary

    Constructors
    Constructor
    Description
    WebSocketClientBlueprint$()
     

  • Method Summary

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

    Methods inherited from class java.lang.Object

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

  • Field Details

    • MODULE$

      public static final WebSocketClientBlueprint$ MODULE$
      Static reference to the singleton instance of this Scala object.

  • Constructor Details

    • WebSocketClientBlueprint$

      public WebSocketClientBlueprint$()

  • Method Details

    • apply

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

    • handshake

      public org.apache.pekko.stream.scaladsl.BidiFlow<org.apache.pekko.util.ByteString,org.apache.pekko.util.ByteString,org.apache.pekko.util.ByteString,org.apache.pekko.util.ByteString,scala.concurrent.Future<WebSocketUpgradeResponse>> handshake(WebSocketRequest request, ClientConnectionSettings settings, org.apache.pekko.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 org.apache.pekko.stream.scaladsl.BidiFlow<org.apache.pekko.stream.TLSProtocol.SslTlsInbound,org.apache.pekko.util.ByteString,org.apache.pekko.util.ByteString,org.apache.pekko.stream.TLSProtocol.SendBytes,org.apache.pekko.NotUsed> simpleTls()