Package akka.http.impl.engine.http2

Class Http2Ext

java.lang.Object

akka.http.impl.engine.http2.Http2Ext

All Implemented Interfaces:

akka.actor.Extension

public final class Http2Ext
extends java.lang.Object
implements akka.actor.Extension

INTERNAL API

Internal entry points for Http/2 server

Constructor Summary

Constructors

Constructor	Description
Http2Ext(akka.actor.ActorSystem system)

Method Summary

Modifier and Type	Method	Description
scala.concurrent.Future<Http.ServerBinding>	bindAndHandleAsync(scala.Function1<HttpRequest,scala.concurrent.Future<HttpResponse>> handler, java.lang.String interface_, int port, ConnectionContext connectionContext, ServerSettings settings, akka.event.LoggingAdapter log, akka.stream.Materializer fm)
Connection	ConnectionUpgradeHeader()
HttpExt	http()
akka.stream.scaladsl.Flow<akka.util.ByteString,akka.util.ByteString,scala.concurrent.Future<ServerTerminator>>	httpsWithAlpn(HttpsConnectionContext httpsContext, akka.stream.scaladsl.Flow<akka.stream.TLSProtocol.SslTlsInbound,akka.stream.TLSProtocol.SslTlsOutbound,ServerTerminator> http1, akka.stream.scaladsl.Flow<akka.stream.TLSProtocol.SslTlsInbound,akka.stream.TLSProtocol.SslTlsOutbound,ServerTerminator> http2)
akka.stream.scaladsl.Flow<HttpRequest,HttpResponse,scala.concurrent.Future<Http.OutgoingConnection>>	outgoingConnection(java.lang.String host, int port, HttpsConnectionContext connectionContext, ClientConnectionSettings clientConnectionSettings, akka.event.LoggingAdapter log)
akka.stream.scaladsl.Flow<HttpRequest,HttpResponse,scala.concurrent.Future<Http.OutgoingConnection>>	outgoingConnectionPriorKnowledge(java.lang.String host, int port, ClientConnectionSettings clientConnectionSettings, akka.event.LoggingAdapter log)
akka.actor.ActorSystem	system()
TelemetrySpi	telemetry()
Upgrade	UpgradeHeader()

Methods inherited from class java.lang.Object

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

Constructor Detail

Http2Ext

public Http2Ext(akka.actor.ActorSystem system)

Method Detail

ConnectionUpgradeHeader

public Connection ConnectionUpgradeHeader()

UpgradeHeader

public Upgrade UpgradeHeader()

bindAndHandleAsync

public scala.concurrent.Future<Http.ServerBinding> bindAndHandleAsync(scala.Function1<HttpRequest,scala.concurrent.Future<HttpResponse>> handler,
                                                                      java.lang.String interface_,
                                                                      int port,
                                                                      ConnectionContext connectionContext,
                                                                      ServerSettings settings,
                                                                      akka.event.LoggingAdapter log,
                                                                      akka.stream.Materializer fm)

http

public HttpExt http()

httpsWithAlpn

public akka.stream.scaladsl.Flow<akka.util.ByteString,akka.util.ByteString,scala.concurrent.Future<ServerTerminator>> httpsWithAlpn(HttpsConnectionContext httpsContext,
                                                                                                                                                akka.stream.scaladsl.Flow<akka.stream.TLSProtocol.SslTlsInbound,akka.stream.TLSProtocol.SslTlsOutbound,ServerTerminator> http1,
                                                                                                                                                akka.stream.scaladsl.Flow<akka.stream.TLSProtocol.SslTlsInbound,akka.stream.TLSProtocol.SslTlsOutbound,ServerTerminator> http2)

outgoingConnection

public akka.stream.scaladsl.Flow<HttpRequest,HttpResponse,scala.concurrent.Future<Http.OutgoingConnection>> outgoingConnection(java.lang.String host,
                                                                                                                                           int port,
                                                                                                                                           HttpsConnectionContext connectionContext,
                                                                                                                                           ClientConnectionSettings clientConnectionSettings,
                                                                                                                                           akka.event.LoggingAdapter log)

outgoingConnectionPriorKnowledge

public akka.stream.scaladsl.Flow<HttpRequest,HttpResponse,scala.concurrent.Future<Http.OutgoingConnection>> outgoingConnectionPriorKnowledge(java.lang.String host,
                                                                                                                                                         int port,
                                                                                                                                                         ClientConnectionSettings clientConnectionSettings,
                                                                                                                                                         akka.event.LoggingAdapter log)

system

public akka.actor.ActorSystem system()

telemetry

public TelemetrySpi telemetry()