Package 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 Object
implements ServerTerminator

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	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 Details

ConnectionTerminator

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

Method Details

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)