org.apache.pekko.http.impl.engine.server

Class GracefulTerminatorStage.ConnectionTerminator

java.lang.Object

org.apache.pekko.http.impl.engine.server.GracefulTerminatorStage.ConnectionTerminator

All Implemented Interfaces:

ServerTerminator

Enclosing class:

GracefulTerminatorStage

public final class GracefulTerminatorStage.ConnectionTerminator
extends java.lang.Object
implements ServerTerminator

Constructor Summary

Constructors

Constructor and Description
ConnectionTerminator(scala.concurrent.Promise<scala.Function1<scala.concurrent.duration.FiniteDuration,scala.concurrent.Future<Http.HttpTerminated>>> triggerTermination)

Method Summary

Modifier and Type	Method and Description
scala.concurrent.Future<Http.HttpTerminated>	terminate(scala.concurrent.duration.FiniteDuration deadline, scala.concurrent.ExecutionContext ec) Initiate the termination sequence of this server.

Methods inherited from class java.lang.Object

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

Constructor Detail

ConnectionTerminator

public ConnectionTerminator(scala.concurrent.Promise<scala.Function1<scala.concurrent.duration.FiniteDuration,scala.concurrent.Future<Http.HttpTerminated>>> triggerTermination)

Method Detail

terminate

public scala.concurrent.Future<Http.HttpTerminated> terminate(scala.concurrent.duration.FiniteDuration deadline,
                                                              scala.concurrent.ExecutionContext ec)

Description copied from interface: ServerTerminator

Initiate the termination sequence of this server.

Specified by:

terminate in interface ServerTerminator

Parameters:

deadline - (undocumented)

ec - (undocumented)

Returns:

(undocumented)