Interface HostConnectionPoolSpec.ClientServerImplementation

All Known Implementing Classes:
HostConnectionPoolSpec.PassThrough$, HostConnectionPoolSpec.PekkoHttpEngineNoNetwork$, HostConnectionPoolSpec.PekkoHttpEngineTCP$, HostConnectionPoolSpec.PekkoHttpEngineTLS$, HostConnectionPoolSpec.TopLevelApiClientServerImplementation
Enclosing class:
HostConnectionPoolSpec

public static interface HostConnectionPoolSpec.ClientServerImplementation
  • Method Summary

    Modifier and Type
    Method
    Description
    boolean
    Specifies if the transport implementation will fail the handler request input side if an error is encountered at the response output side.
    org.apache.pekko.stream.scaladsl.BidiFlow<HttpResponse,HttpResponse,HttpRequest,HttpRequest,scala.concurrent.Future<Http.OutgoingConnection>>
    get(org.apache.pekko.stream.SharedKillSwitch connectionKillSwitch)
    Returns a client / server implementation that include the kill switch flow in the middle
  • Method Details

    • failsHandlerInputWhenHandlerOutputFails

      boolean failsHandlerInputWhenHandlerOutputFails()
      Specifies if the transport implementation will fail the handler request input side if an error is encountered at the response output side.

      I haven't decided yet what the right behavior should be.

      Returns:
      (undocumented)
    • get

      org.apache.pekko.stream.scaladsl.BidiFlow<HttpResponse,HttpResponse,HttpRequest,HttpRequest,scala.concurrent.Future<Http.OutgoingConnection>> get(org.apache.pekko.stream.SharedKillSwitch connectionKillSwitch)
      Returns a client / server implementation that include the kill switch flow in the middle