Package org.apache.pekko.http.impl.engine.client

Interface PoolInterface

public interface PoolInterface

The pool interface is a push style interface to a pool of connections against a single host.

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static class	PoolInterface.PoolInterfaceStage
static interface	PoolInterface.ShutdownReason
static class	PoolInterface.ShutdownReason$

Method Summary

Modifier and Type	Method	Description
void	request(HttpRequest request, scala.concurrent.Promise<HttpResponse> responsePromise)	Submit request to pool.
scala.concurrent.Future<PoolInterface.ShutdownReason>	shutdown(scala.concurrent.ExecutionContext ec)
scala.concurrent.Future<PoolInterface.ShutdownReason>	whenShutdown()

Method Details

request

void request(HttpRequest request,
 scala.concurrent.Promise<HttpResponse> responsePromise)

Submit request to pool. After completion the pool will complete the promise with the response. If the queue in front of the pool is full, the promise will be failed with a BufferOverflowException.

Parameters:

request - (undocumented)

responsePromise - (undocumented)

shutdown

scala.concurrent.Future<PoolInterface.ShutdownReason> shutdown(scala.concurrent.ExecutionContext ec)

whenShutdown

scala.concurrent.Future<PoolInterface.ShutdownReason> whenShutdown()