Packages

class Http extends Extension

Source
Http.scala
Linear Supertypes
Extension, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. Http
  2. Extension
  3. AnyRef
  4. Any
Implicitly
  1. by any2stringadd
  2. by StringFormat
  3. by Ensuring
  4. by ArrowAssoc
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new Http(system: ExtendedActorSystem)

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int
    Definition Classes
    AnyRef → Any
  3. def +(other: String): String
    Implicit
    This member is added by an implicit conversion from Http to any2stringadd[Http] performed by method any2stringadd in scala.Predef.
    Definition Classes
    any2stringadd
  4. def ->[B](y: B): (Http, B)
    Implicit
    This member is added by an implicit conversion from Http to ArrowAssoc[Http] performed by method ArrowAssoc in scala.Predef.
    Definition Classes
    ArrowAssoc
    Annotations
    @inline()
  5. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  6. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  7. def bind(connect: ConnectHttp, settings: ServerSettings, log: LoggingAdapter): Source[IncomingConnection, CompletionStage[ServerBinding]]

    Creates a akka.stream.javadsl.Source of IncomingConnection instances which represents a prospective HTTP server binding on the given endpoint.

    Creates a akka.stream.javadsl.Source of IncomingConnection instances which represents a prospective HTTP server binding on the given endpoint.

    If the given port is 0 the resulting source can be materialized several times. Each materialization will then be assigned a new local port by the operating system, which can then be retrieved by the materialized ServerBinding.

    If the given port is non-zero subsequent materialization attempts of the produced source will immediately fail, unless the first materialization has already been unbound. Unbinding can be triggered via the materialized ServerBinding.

    The server will be bound using HTTPS if the ConnectHttp object is configured with an HttpsConnectionContext, or the defaultServerHttpContext has been configured to be an HttpsConnectionContext.

  8. def bind(connect: ConnectHttp, settings: ServerSettings): Source[IncomingConnection, CompletionStage[ServerBinding]]

    Creates a akka.stream.javadsl.Source of IncomingConnection instances which represents a prospective HTTP server binding on the given endpoint.

    Creates a akka.stream.javadsl.Source of IncomingConnection instances which represents a prospective HTTP server binding on the given endpoint.

    If the given port is 0 the resulting source can be materialized several times. Each materialization will then be assigned a new local port by the operating system, which can then be retrieved by the materialized ServerBinding.

    If the given port is non-zero subsequent materialization attempts of the produced source will immediately fail, unless the first materialization has already been unbound. Unbinding can be triggered via the materialized ServerBinding.

    The server will be bound using HTTPS if the ConnectHttp object is configured with an HttpsConnectionContext, or the defaultServerHttpContext has been configured to be an HttpsConnectionContext.

  9. def bind(connect: ConnectHttp): Source[IncomingConnection, CompletionStage[ServerBinding]]

    Creates a akka.stream.javadsl.Source of IncomingConnection instances which represents a prospective HTTP server binding on the given endpoint.

    Creates a akka.stream.javadsl.Source of IncomingConnection instances which represents a prospective HTTP server binding on the given endpoint.

    If the given port is 0 the resulting source can be materialized several times. Each materialization will then be assigned a new local port by the operating system, which can then be retrieved by the materialized ServerBinding.

    If the given port is non-zero subsequent materialization attempts of the produced source will immediately fail, unless the first materialization has already been unbound. Unbinding can be triggered via the materialized ServerBinding.

    The server will be bound using HTTPS if the ConnectHttp object is configured with an HttpsConnectionContext, or the defaultServerHttpContext has been configured to be an HttpsConnectionContext.

  10. def bindAndHandle(handler: Flow[HttpRequest, HttpResponse, _], connect: ConnectHttp, settings: ServerSettings, log: LoggingAdapter, materializer: Materializer): CompletionStage[ServerBinding]

    Convenience method which starts a new HTTP server at the given endpoint and uses the given handler akka.stream.javadsl.Flow for processing all incoming connections.

    Convenience method which starts a new HTTP server at the given endpoint and uses the given handler akka.stream.javadsl.Flow for processing all incoming connections.

    The number of concurrently accepted connections can be configured by overriding the akka.http.server.max-connections setting. Please see the documentation in the reference.conf for more information about what kind of guarantees to expect.

    The server will be bound using HTTPS if the ConnectHttp object is configured with an HttpsConnectionContext, or the defaultServerHttpContext has been configured to be an HttpsConnectionContext.

  11. def bindAndHandle(handler: Flow[HttpRequest, HttpResponse, _], connect: ConnectHttp, materializer: Materializer): CompletionStage[ServerBinding]

    Convenience method which starts a new HTTP server at the given endpoint and uses the given handler akka.stream.javadsl.Flow for processing all incoming connections.

    Convenience method which starts a new HTTP server at the given endpoint and uses the given handler akka.stream.javadsl.Flow for processing all incoming connections.

    The number of concurrently accepted connections can be configured by overriding the akka.http.server.max-connections setting. Please see the documentation in the reference.conf for more information about what kind of guarantees to expect.

    The server will be bound using HTTPS if the ConnectHttp object is configured with an HttpsConnectionContext, or the defaultServerHttpContext has been configured to be an HttpsConnectionContext.

  12. def bindAndHandleAsync(handler: Function[HttpRequest, CompletionStage[HttpResponse]], connect: ConnectHttp, settings: ServerSettings, parallelism: Int, log: LoggingAdapter, materializer: Materializer): CompletionStage[ServerBinding]

    Convenience method which starts a new HTTP server at the given endpoint and uses the given handler akka.stream.javadsl.Flow for processing all incoming connections.

    Convenience method which starts a new HTTP server at the given endpoint and uses the given handler akka.stream.javadsl.Flow for processing all incoming connections.

    The number of concurrently accepted connections can be configured by overriding the akka.http.server.max-connections setting. Please see the documentation in the reference.conf for more information about what kind of guarantees to expect.

    The server will be bound using HTTPS if the ConnectHttp object is configured with an HttpsConnectionContext, or the defaultServerHttpContext has been configured to be an HttpsConnectionContext.

  13. def bindAndHandleAsync(handler: Function[HttpRequest, CompletionStage[HttpResponse]], connect: ConnectHttp, materializer: Materializer): CompletionStage[ServerBinding]

    Convenience method which starts a new HTTP server at the given endpoint and uses the given handler akka.stream.javadsl.Flow for processing all incoming connections.

    Convenience method which starts a new HTTP server at the given endpoint and uses the given handler akka.stream.javadsl.Flow for processing all incoming connections.

    The number of concurrently accepted connections can be configured by overriding the akka.http.server.max-connections setting. Please see the documentation in the reference.conf for more information about what kind of guarantees to expect.

    The server will be bound using HTTPS if the ConnectHttp object is configured with an HttpsConnectionContext, or the defaultServerHttpContext has been configured to be an HttpsConnectionContext.

  14. def bindAndHandleSync(handler: Function[HttpRequest, HttpResponse], connect: ConnectHttp, settings: ServerSettings, log: LoggingAdapter, materializer: Materializer): CompletionStage[ServerBinding]

    Convenience method which starts a new HTTP server at the given endpoint and uses the given handler akka.stream.javadsl.Flow for processing all incoming connections.

    Convenience method which starts a new HTTP server at the given endpoint and uses the given handler akka.stream.javadsl.Flow for processing all incoming connections.

    The number of concurrently accepted connections can be configured by overriding the akka.http.server.max-connections setting. Please see the documentation in the reference.conf for more information about what kind of guarantees to expect.

    The server will be bound using HTTPS if the ConnectHttp object is configured with an HttpsConnectionContext, or the defaultServerHttpContext has been configured to be an HttpsConnectionContext.

  15. def bindAndHandleSync(handler: Function[HttpRequest, HttpResponse], connect: ConnectHttp, materializer: Materializer): CompletionStage[ServerBinding]

    Convenience method which starts a new HTTP server at the given endpoint and uses the given handler akka.stream.javadsl.Flow for processing all incoming connections.

    Convenience method which starts a new HTTP server at the given endpoint and uses the given handler akka.stream.javadsl.Flow for processing all incoming connections.

    The number of concurrently accepted connections can be configured by overriding the akka.http.server.max-connections setting. Please see the documentation in the reference.conf for more information about what kind of guarantees to expect.

    The server will be bound using HTTPS if the ConnectHttp object is configured with an HttpsConnectionContext, or the defaultServerHttpContext has been configured to be an HttpsConnectionContext.

  16. def cachedHostConnectionPool[T](to: ConnectHttp, settings: ConnectionPoolSettings, log: LoggingAdapter): Flow[Pair[HttpRequest, T], Pair[Try[HttpResponse], T], HostConnectionPool]

    Returns a akka.stream.javadsl.Flow which dispatches incoming HTTP requests to the per-ActorSystem pool of outgoing HTTP connections to the given target host endpoint.

    Returns a akka.stream.javadsl.Flow which dispatches incoming HTTP requests to the per-ActorSystem pool of outgoing HTTP connections to the given target host endpoint. For every ActorSystem, target host and pool configuration a separate connection pool is maintained. The HTTP layer transparently manages idle shutdown and restarting of connections pools as configured. The returned akka.stream.javadsl.Flow instances therefore remain valid throughout the lifetime of the application.

    The internal caching logic guarantees that there will never be more than a single pool running for the given target host endpoint and configuration (in this ActorSystem).

    Since the underlying transport usually comprises more than a single connection the produced flow might generate responses in an order that doesn't directly match the consumed requests. For example, if two requests A and B enter the flow in that order the response for B might be produced before the response for A. In order to allow for easy response-to-request association the flow takes in a custom, opaque context object of type T from the application which is emitted together with the corresponding response.

    To configure additional settings for the pool (and requests made using it), use the akka.http.host-connection-pool config section or pass in a ConnectionPoolSettings explicitly.

  17. def cachedHostConnectionPool[T](to: ConnectHttp): Flow[Pair[HttpRequest, T], Pair[Try[HttpResponse], T], HostConnectionPool]

    Returns a akka.stream.javadsl.Flow which dispatches incoming HTTP requests to the per-ActorSystem pool of outgoing HTTP connections to the given target host endpoint.

    Returns a akka.stream.javadsl.Flow which dispatches incoming HTTP requests to the per-ActorSystem pool of outgoing HTTP connections to the given target host endpoint. For every ActorSystem, target host and pool configuration a separate connection pool is maintained. The HTTP layer transparently manages idle shutdown and restarting of connections pools as configured. The returned akka.stream.javadsl.Flow instances therefore remain valid throughout the lifetime of the application.

    The internal caching logic guarantees that there will never be more than a single pool running for the given target host endpoint and configuration (in this ActorSystem).

    Since the underlying transport usually comprises more than a single connection the produced flow might generate responses in an order that doesn't directly match the consumed requests. For example, if two requests A and B enter the flow in that order the response for B might be produced before the response for A. In order to allow for easy response-to-request association the flow takes in a custom, opaque context object of type T from the application which is emitted together with the corresponding response.

  18. def cachedHostConnectionPool[T](host: String): Flow[Pair[HttpRequest, T], Pair[Try[HttpResponse], T], HostConnectionPool]

    Returns a akka.stream.javadsl.Flow which dispatches incoming HTTP requests to the per-ActorSystem pool of outgoing HTTP connections to the given target host endpoint.

    Returns a akka.stream.javadsl.Flow which dispatches incoming HTTP requests to the per-ActorSystem pool of outgoing HTTP connections to the given target host endpoint. For every ActorSystem, target host and pool configuration a separate connection pool is maintained. The HTTP layer transparently manages idle shutdown and restarting of connections pools as configured. The returned akka.stream.javadsl.Flow instances therefore remain valid throughout the lifetime of the application.

    The internal caching logic guarantees that there will never be more than a single pool running for the given target host endpoint and configuration (in this ActorSystem).

    Since the underlying transport usually comprises more than a single connection the produced flow might generate responses in an order that doesn't directly match the consumed requests. For example, if two requests A and B enter the flow in that order the response for B might be produced before the response for A. In order to allow for easy response-to-request association the flow takes in a custom, opaque context object of type T from the application which is emitted together with the corresponding response.

  19. def cachedHostConnectionPoolHttps[T](to: ConnectHttp): Flow[Pair[HttpRequest, T], Pair[Try[HttpResponse], T], HostConnectionPool]

    Same as cachedHostConnectionPool but with HTTPS encryption.

    Same as cachedHostConnectionPool but with HTTPS encryption.

    When an HttpConnectionContext is defined in the given ConnectHttp it will be used, otherwise the default client-side context will be used.

  20. def cachedHostConnectionPoolHttps[T](to: ConnectHttp, settings: ConnectionPoolSettings, log: LoggingAdapter): Flow[Pair[HttpRequest, T], Pair[Try[HttpResponse], T], HostConnectionPool]

    Same as cachedHostConnectionPool but with HTTPS encryption.

    Same as cachedHostConnectionPool but with HTTPS encryption.

    When an HttpConnectionContext is defined in the given ConnectHttp it will be used, otherwise the default client-side context will be used.

  21. def clientLayer(hostHeader: Host, settings: ClientConnectionSettings, log: LoggingAdapter): BidiFlow[HttpRequest, SslTlsOutbound, SslTlsInbound, HttpResponse, NotUsed]

    Constructs a client layer stage using the given ClientConnectionSettings.

  22. def clientLayer(hostHeader: Host, settings: ClientConnectionSettings): BidiFlow[HttpRequest, SslTlsOutbound, SslTlsInbound, HttpResponse, NotUsed]

    Constructs a client layer stage using the given akka.http.javadsl.settings.ClientConnectionSettings.

  23. def clientLayer(hostHeader: Host): BidiFlow[HttpRequest, SslTlsOutbound, SslTlsInbound, HttpResponse, NotUsed]

    Constructs a client layer stage using the configured default akka.http.javadsl.settings.ClientConnectionSettings.

  24. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()
  25. def createClientHttpsContext(sslConfig: AkkaSSLConfig): HttpsConnectionContext
  26. def createDefaultClientHttpsContext(): HttpsConnectionContext
  27. def createServerHttpsContext(sslConfig: AkkaSSLConfig): HttpsConnectionContext
  28. def defaultClientHttpsContext: HttpsConnectionContext

    Gets the current default client-side ConnectionContext.

  29. def defaultServerHttpContext: ConnectionContext

    Gets the current default server-side ConnectionContext – defaults to plain HTTP.

    Gets the current default server-side ConnectionContext – defaults to plain HTTP. Can be modified using setDefaultServerHttpContext, and will then apply for servers bound after that call has completed.

  30. def ensuring(cond: (Http) ⇒ Boolean, msg: ⇒ Any): Http
    Implicit
    This member is added by an implicit conversion from Http to Ensuring[Http] performed by method Ensuring in scala.Predef.
    Definition Classes
    Ensuring
  31. def ensuring(cond: (Http) ⇒ Boolean): Http
    Implicit
    This member is added by an implicit conversion from Http to Ensuring[Http] performed by method Ensuring in scala.Predef.
    Definition Classes
    Ensuring
  32. def ensuring(cond: Boolean, msg: ⇒ Any): Http
    Implicit
    This member is added by an implicit conversion from Http to Ensuring[Http] performed by method Ensuring in scala.Predef.
    Definition Classes
    Ensuring
  33. def ensuring(cond: Boolean): Http
    Implicit
    This member is added by an implicit conversion from Http to Ensuring[Http] performed by method Ensuring in scala.Predef.
    Definition Classes
    Ensuring
  34. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  35. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  36. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  37. def formatted(fmtstr: String): String
    Implicit
    This member is added by an implicit conversion from Http to StringFormat[Http] performed by method StringFormat in scala.Predef.
    Definition Classes
    StringFormat
    Annotations
    @inline()
  38. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  39. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  40. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  41. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  42. def newHostConnectionPool[T](to: ConnectHttp, settings: ConnectionPoolSettings, log: LoggingAdapter, materializer: Materializer): Flow[Pair[HttpRequest, T], Pair[Try[HttpResponse], T], HostConnectionPool]

    Same as newHostConnectionPool but with HTTPS encryption.

    Same as newHostConnectionPool but with HTTPS encryption.

    The given ConnectionContext will be used for encryption on the connection.

  43. def newHostConnectionPool[T](to: ConnectHttp, materializer: Materializer): Flow[Pair[HttpRequest, T], Pair[Try[HttpResponse], T], HostConnectionPool]

    Starts a new connection pool to the given host and configuration and returns a akka.stream.javadsl.Flow which dispatches the requests from all its materializations across this pool.

    Starts a new connection pool to the given host and configuration and returns a akka.stream.javadsl.Flow which dispatches the requests from all its materializations across this pool. While the started host connection pool internally shuts itself down automatically after the configured idle timeout it will spin itself up again if more requests arrive from an existing or a new client flow materialization. The returned flow therefore remains usable for the full lifetime of the application.

    Since the underlying transport usually comprises more than a single connection the produced flow might generate responses in an order that doesn't directly match the consumed requests. For example, if two requests A and B enter the flow in that order the response for B might be produced before the response for A. In order to allow for easy response-to-request association the flow takes in a custom, opaque context object of type T from the application which is emitted together with the corresponding response.

  44. def newHostConnectionPool[T](host: String, materializer: Materializer): Flow[Pair[HttpRequest, T], Pair[Try[HttpResponse], T], HostConnectionPool]

    Starts a new connection pool to the given host and configuration and returns a akka.stream.javadsl.Flow which dispatches the requests from all its materializations across this pool.

    Starts a new connection pool to the given host and configuration and returns a akka.stream.javadsl.Flow which dispatches the requests from all its materializations across this pool. While the started host connection pool internally shuts itself down automatically after the configured idle timeout it will spin itself up again if more requests arrive from an existing or a new client flow materialization. The returned flow therefore remains usable for the full lifetime of the application.

    Since the underlying transport usually comprises more than a single connection the produced flow might generate responses in an order that doesn't directly match the consumed requests. For example, if two requests A and B enter the flow in that order the response for B might be produced before the response for A. In order to allow for easy response-to-request association the flow takes in a custom, opaque context object of type T from the application which is emitted together with the corresponding response.

  45. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  46. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  47. def outgoingConnection(to: ConnectHttp, localAddress: Optional[InetSocketAddress], settings: ClientConnectionSettings, log: LoggingAdapter): Flow[HttpRequest, HttpResponse, CompletionStage[OutgoingConnection]]

    Creates a akka.stream.javadsl.Flow representing a prospective HTTP client connection to the given endpoint.

    Creates a akka.stream.javadsl.Flow representing a prospective HTTP client connection to the given endpoint. Every materialization of the produced flow will attempt to establish a new outgoing connection.

  48. def outgoingConnection(to: ConnectHttp): Flow[HttpRequest, HttpResponse, CompletionStage[OutgoingConnection]]

    Creates a akka.stream.javadsl.Flow representing a prospective HTTP client connection to the given endpoint.

    Creates a akka.stream.javadsl.Flow representing a prospective HTTP client connection to the given endpoint. Every materialization of the produced flow will attempt to establish a new outgoing connection.

    Use the ConnectHttp DSL to configure target host and whether HTTPS should be used.

  49. def outgoingConnection(host: String): Flow[HttpRequest, HttpResponse, CompletionStage[OutgoingConnection]]

    Creates a akka.stream.javadsl.Flow representing a prospective HTTP client connection to the given endpoint.

    Creates a akka.stream.javadsl.Flow representing a prospective HTTP client connection to the given endpoint. Every materialization of the produced flow will attempt to establish a new outgoing connection.

    If the hostname is given with an https:// prefix, the default HttpsConnectionContext will be used.

  50. def serverLayer(settings: ServerSettings, remoteAddress: Optional[InetSocketAddress], log: LoggingAdapter): BidiFlow[HttpResponse, SslTlsOutbound, SslTlsInbound, HttpRequest, NotUsed]

    Constructs a server layer stage using the given ServerSettings.

    Constructs a server layer stage using the given ServerSettings. The returned akka.stream.javadsl.BidiFlow isn't reusable and can only be materialized once. The remoteAddress, if provided, will be added as a header to each HttpRequest this layer produces if the akka.http.server.remote-address-header configuration option is enabled.

  51. def serverLayer(settings: ServerSettings, remoteAddress: Optional[InetSocketAddress]): BidiFlow[HttpResponse, SslTlsOutbound, SslTlsInbound, HttpRequest, NotUsed]

    Constructs a server layer stage using the given akka.http.javadsl.settings.ServerSettings.

    Constructs a server layer stage using the given akka.http.javadsl.settings.ServerSettings. The returned akka.stream.javadsl.BidiFlow isn't reusable and can only be materialized once. The remoteAddress, if provided, will be added as a header to each HttpRequest this layer produces if the akka.http.server.remote-address-header configuration option is enabled.

  52. def serverLayer(settings: ServerSettings): BidiFlow[HttpResponse, SslTlsOutbound, SslTlsInbound, HttpRequest, NotUsed]

    Constructs a server layer stage using the given akka.http.javadsl.settings.ServerSettings.

    Constructs a server layer stage using the given akka.http.javadsl.settings.ServerSettings. The returned akka.stream.javadsl.BidiFlow isn't reusable and can only be materialized once.

  53. def serverLayer(): BidiFlow[HttpResponse, SslTlsOutbound, SslTlsInbound, HttpRequest, NotUsed]

    Constructs a server layer stage using the configured default akka.http.javadsl.settings.ServerSettings.

    Constructs a server layer stage using the configured default akka.http.javadsl.settings.ServerSettings. The returned akka.stream.javadsl.BidiFlow isn't reusable and can only be materialized once.

  54. def setDefaultClientHttpsContext(context: HttpsConnectionContext): Unit

    Sets the default client-side ConnectionContext.

  55. def setDefaultServerHttpContext(context: ConnectionContext): Unit

    Sets the default server-side ConnectionContext.

    Sets the default server-side ConnectionContext. If it is an instance of HttpsConnectionContext then the server will be bound using HTTPS.

  56. def shutdownAllConnectionPools(): CompletionStage[Unit]

    Triggers an orderly shutdown of all host connections pools currently maintained by the akka.actor.ActorSystem.

    Triggers an orderly shutdown of all host connections pools currently maintained by the akka.actor.ActorSystem. The returned future is completed when all pools that were live at the time of this method call have completed their shutdown process.

    If existing pool client flows are re-used or new ones materialized concurrently with or after this method call the respective connection pools will be restarted and not contribute to the returned future.

  57. def singleRequest(request: HttpRequest, connectionContext: HttpsConnectionContext, settings: ConnectionPoolSettings, log: LoggingAdapter): CompletionStage[HttpResponse]

    Fires a single HttpRequest across the (cached) host connection pool for the request's effective URI to produce a response future.

    Fires a single HttpRequest across the (cached) host connection pool for the request's effective URI to produce a response future.

    The given HttpsConnectionContext will be used for encryption if the request is sent to an https endpoint.

    Note that the request must have either an absolute URI or a valid Host header, otherwise the future will be completed with an error.

  58. def singleRequest(request: HttpRequest, connectionContext: HttpsConnectionContext): CompletionStage[HttpResponse]

    Fires a single HttpRequest across the (cached) host connection pool for the request's effective URI to produce a response future.

    Fires a single HttpRequest across the (cached) host connection pool for the request's effective URI to produce a response future.

    The defaultClientHttpsContext is used to configure TLS for the connection.

    Note that the request must have either an absolute URI or a valid Host header, otherwise the future will be completed with an error.

  59. def singleRequest(request: HttpRequest): CompletionStage[HttpResponse]

    Fires a single HttpRequest across the (cached) host connection pool for the request's effective URI to produce a response future.

    Fires a single HttpRequest across the (cached) host connection pool for the request's effective URI to produce a response future.

    The defaultClientHttpsContext is used to configure TLS for the connection.

    Note that the request must have either an absolute URI or a valid Host header, otherwise the future will be completed with an error.

  60. def singleWebSocketRequest[T](request: WebSocketRequest, clientFlow: Flow[Message, Message, T], connectionContext: ConnectionContext, localAddress: Optional[InetSocketAddress], settings: ClientConnectionSettings, log: LoggingAdapter, materializer: Materializer): Pair[CompletionStage[WebSocketUpgradeResponse], T]

    Runs a single WebSocket conversation given a Uri and a flow that represents the client side of the WebSocket conversation.

  61. def singleWebSocketRequest[T](request: WebSocketRequest, clientFlow: Flow[Message, Message, T], connectionContext: ConnectionContext, materializer: Materializer): Pair[CompletionStage[WebSocketUpgradeResponse], T]

    Runs a single WebSocket conversation given a Uri and a flow that represents the client side of the WebSocket conversation.

    Runs a single WebSocket conversation given a Uri and a flow that represents the client side of the WebSocket conversation.

    The defaultClientHttpsContext is used to configure TLS for the connection.

  62. def singleWebSocketRequest[T](request: WebSocketRequest, clientFlow: Flow[Message, Message, T], materializer: Materializer): Pair[CompletionStage[WebSocketUpgradeResponse], T]

    Runs a single WebSocket conversation given a Uri and a flow that represents the client side of the WebSocket conversation.

    Runs a single WebSocket conversation given a Uri and a flow that represents the client side of the WebSocket conversation.

    The defaultClientHttpsContext is used to configure TLS for the connection.

  63. def superPool[T](settings: ConnectionPoolSettings, log: LoggingAdapter): Flow[Pair[HttpRequest, T], Pair[Try[HttpResponse], T], NotUsed]

    Creates a new "super connection pool flow", which routes incoming requests to a (cached) host connection pool depending on their respective effective URIs.

    Creates a new "super connection pool flow", which routes incoming requests to a (cached) host connection pool depending on their respective effective URIs. Note that incoming requests must have either an absolute URI or a valid Host header.

    The defaultClientHttpsContext is used to configure TLS for the connection.

    Since the underlying transport usually comprises more than a single connection the produced flow might generate responses in an order that doesn't directly match the consumed requests. For example, if two requests A and B enter the flow in that order the response for B might be produced before the response for A.

    In order to allow for easy response-to-request association the flow takes in a custom, opaque context object of type T from the application which is emitted together with the corresponding response.

  64. def superPool[T](settings: ConnectionPoolSettings, connectionContext: HttpsConnectionContext, log: LoggingAdapter): Flow[Pair[HttpRequest, T], Pair[Try[HttpResponse], T], NotUsed]

    Creates a new "super connection pool flow", which routes incoming requests to a (cached) host connection pool depending on their respective effective URIs.

    Creates a new "super connection pool flow", which routes incoming requests to a (cached) host connection pool depending on their respective effective URIs. Note that incoming requests must have either an absolute URI or a valid Host header.

    The given HttpsConnectionContext is used to configure TLS for the connection.

    Since the underlying transport usually comprises more than a single connection the produced flow might generate responses in an order that doesn't directly match the consumed requests. For example, if two requests A and B enter the flow in that order the response for B might be produced before the response for A.

    In order to allow for easy response-to-request association the flow takes in a custom, opaque context object of type T from the application which is emitted together with the corresponding response.

  65. def superPool[T](): Flow[Pair[HttpRequest, T], Pair[Try[HttpResponse], T], NotUsed]

    Creates a new "super connection pool flow", which routes incoming requests to a (cached) host connection pool depending on their respective effective URIs.

    Creates a new "super connection pool flow", which routes incoming requests to a (cached) host connection pool depending on their respective effective URIs. Note that incoming requests must have either an absolute URI or a valid Host header.

    Since the underlying transport usually comprises more than a single connection the produced flow might generate responses in an order that doesn't directly match the consumed requests. For example, if two requests A and B enter the flow in that order the response for B might be produced before the response for A. In order to allow for easy response-to-request association the flow takes in a custom, opaque context object of type T from the application which is emitted together with the corresponding response.

  66. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  67. def toString(): String
    Definition Classes
    AnyRef → Any
  68. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  69. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  70. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()
  71. def webSocketClientFlow(request: WebSocketRequest, connectionContext: ConnectionContext, localAddress: Optional[InetSocketAddress], settings: ClientConnectionSettings, log: LoggingAdapter): Flow[Message, Message, CompletionStage[WebSocketUpgradeResponse]]

    Constructs a flow that once materialized establishes a WebSocket connection to the given Uri.

    Constructs a flow that once materialized establishes a WebSocket connection to the given Uri.

    The layer is not reusable and must only be materialized once.

  72. def webSocketClientFlow(request: WebSocketRequest): Flow[Message, Message, CompletionStage[WebSocketUpgradeResponse]]

    Constructs a flow that once materialized establishes a WebSocket connection to the given Uri.

    Constructs a flow that once materialized establishes a WebSocket connection to the given Uri.

    The layer is not reusable and must only be materialized once.

  73. def webSocketClientLayer(request: WebSocketRequest, settings: ClientConnectionSettings, log: LoggingAdapter): BidiFlow[Message, SslTlsOutbound, SslTlsInbound, Message, CompletionStage[WebSocketUpgradeResponse]]

    Constructs a WebSocket akka.stream.javadsl.BidiFlow using the configured default ClientConnectionSettings, configured using the akka.http.client config section.

    Constructs a WebSocket akka.stream.javadsl.BidiFlow using the configured default ClientConnectionSettings, configured using the akka.http.client config section.

    The layer is not reusable and must only be materialized once.

  74. def webSocketClientLayer(request: WebSocketRequest, settings: ClientConnectionSettings): BidiFlow[Message, SslTlsOutbound, SslTlsInbound, Message, CompletionStage[WebSocketUpgradeResponse]]

    Constructs a WebSocket akka.stream.javadsl.BidiFlow using the configured default ClientConnectionSettings, configured using the akka.http.client config section.

    Constructs a WebSocket akka.stream.javadsl.BidiFlow using the configured default ClientConnectionSettings, configured using the akka.http.client config section.

    The layer is not reusable and must only be materialized once.

  75. def webSocketClientLayer(request: WebSocketRequest): BidiFlow[Message, SslTlsOutbound, SslTlsInbound, Message, CompletionStage[WebSocketUpgradeResponse]]

    Constructs a WebSocket akka.stream.javadsl.BidiFlow.

    Constructs a WebSocket akka.stream.javadsl.BidiFlow.

    The layer is not reusable and must only be materialized once.

  76. def →[B](y: B): (Http, B)
    Implicit
    This member is added by an implicit conversion from Http to ArrowAssoc[Http] performed by method ArrowAssoc in scala.Predef.
    Definition Classes
    ArrowAssoc

Deprecated Value Members

  1. def bind(connect: ConnectHttp, settings: ServerSettings, log: LoggingAdapter, materializer: Materializer): Source[IncomingConnection, CompletionStage[ServerBinding]]

    Annotations
    @Deprecated
    Deprecated

    in favor of method that doesn't require materializer. You can just remove the materializer argument.

  2. def bind(connect: ConnectHttp, settings: ServerSettings, materializer: Materializer): Source[IncomingConnection, CompletionStage[ServerBinding]]

    Annotations
    @Deprecated
    Deprecated

    in favor of method that doesn't require materializer. You can just remove the materializer argument.

  3. def bind(connect: ConnectHttp, materializer: Materializer): Source[IncomingConnection, CompletionStage[ServerBinding]]

    Annotations
    @Deprecated
    Deprecated

    in favor of method that doesn't require materializer. You can just remove the materializer argument.

  4. def cachedHostConnectionPool[T](to: ConnectHttp, settings: ConnectionPoolSettings, log: LoggingAdapter, materializer: Materializer): Flow[Pair[HttpRequest, T], Pair[Try[HttpResponse], T], HostConnectionPool]

    Annotations
    @Deprecated
    Deprecated

    in favor of method that doesn't require materializer. You can just remove the materializer argument.

  5. def cachedHostConnectionPool[T](to: ConnectHttp, materializer: Materializer): Flow[Pair[HttpRequest, T], Pair[Try[HttpResponse], T], HostConnectionPool]

    Annotations
    @Deprecated
    Deprecated

    in favor of method that doesn't require materializer. You can just remove the materializer argument.

  6. def cachedHostConnectionPool[T](host: String, materializer: Materializer): Flow[Pair[HttpRequest, T], Pair[Try[HttpResponse], T], HostConnectionPool]

    Annotations
    @Deprecated
    Deprecated

    in favor of method that doesn't require materializer. You can just remove the materializer argument.

  7. def serverLayer(settings: ServerSettings, remoteAddress: Optional[InetSocketAddress], log: LoggingAdapter, materializer: Materializer): BidiFlow[HttpResponse, SslTlsOutbound, SslTlsInbound, HttpRequest, NotUsed]

    Annotations
    @Deprecated
    Deprecated

    in favor of method that doesn't require materializer. You can just remove the materializer argument.

  8. def serverLayer(settings: ServerSettings, remoteAddress: Optional[InetSocketAddress], materializer: Materializer): BidiFlow[HttpResponse, SslTlsOutbound, SslTlsInbound, HttpRequest, NotUsed]

    Annotations
    @Deprecated
    Deprecated

    in favor of method that doesn't require materializer. You can just remove the materializer argument.

  9. def serverLayer(settings: ServerSettings, materializer: Materializer): BidiFlow[HttpResponse, SslTlsOutbound, SslTlsInbound, HttpRequest, NotUsed]

    Annotations
    @Deprecated
    Deprecated

    in favor of method that doesn't require materializer. You can just remove the materializer argument.

  10. def serverLayer(materializer: Materializer): BidiFlow[HttpResponse, SslTlsOutbound, SslTlsInbound, HttpRequest, NotUsed]

    Annotations
    @Deprecated
    Deprecated

    in favor of method that doesn't require materializer. You can just remove the materializer argument.

  11. def singleRequest(request: HttpRequest, connectionContext: HttpsConnectionContext, settings: ConnectionPoolSettings, log: LoggingAdapter, materializer: Materializer): CompletionStage[HttpResponse]

    Annotations
    @Deprecated
    Deprecated

    in favor of method that doesn't require materializer. You can just remove the materializer argument.

  12. def singleRequest(request: HttpRequest, connectionContext: HttpsConnectionContext, materializer: Materializer): CompletionStage[HttpResponse]

    Annotations
    @Deprecated
    Deprecated

    in favor of method that doesn't require materializer. You can just remove the materializer argument.

  13. def singleRequest(request: HttpRequest, materializer: Materializer): CompletionStage[HttpResponse]

    Annotations
    @Deprecated
    Deprecated

    in favor of method that doesn't require materializer. You can just remove the materializer argument.

  14. def superPool[T](settings: ConnectionPoolSettings, connectionContext: HttpsConnectionContext, log: LoggingAdapter, materializer: Materializer): Flow[Pair[HttpRequest, T], Pair[Try[HttpResponse], T], NotUsed]

    Annotations
    @Deprecated
    Deprecated

    in favor of method that doesn't require materializer. You can just remove the materializer argument.

  15. def superPool[T](settings: ConnectionPoolSettings, log: LoggingAdapter, materializer: Materializer): Flow[Pair[HttpRequest, T], Pair[Try[HttpResponse], T], NotUsed]

    Annotations
    @Deprecated
    Deprecated

    in favor of method that doesn't require materializer. You can just remove the materializer argument.

  16. def superPool[T](materializer: Materializer): Flow[Pair[HttpRequest, T], Pair[Try[HttpResponse], T], NotUsed]

    Annotations
    @Deprecated
    Deprecated

    in favor of method that doesn't require materializer. You can just remove the materializer argument.

Inherited from Extension

Inherited from AnyRef

Inherited from Any

Inherited by implicit conversion any2stringadd from Http to any2stringadd[Http]

Inherited by implicit conversion StringFormat from Http to StringFormat[Http]

Inherited by implicit conversion Ensuring from Http to Ensuring[Http]

Inherited by implicit conversion ArrowAssoc from Http to ArrowAssoc[Http]

Ungrouped