Class RouteSegmentedConnPool.Waiter

java.lang.Object

java.util.concurrent.CompletableFuture<PoolEntry<R,C>>

org.apache.hc.core5.pool.RouteSegmentedConnPool.Waiter

All Implemented Interfaces:

CompletionStage<PoolEntry<R,C>>, Future<PoolEntry<R,C>>

Enclosing class:

RouteSegmentedConnPool<R, C extends ModalCloseable>

final class RouteSegmentedConnPool.Waiter
extends CompletableFuture<PoolEntry<R,C>>

Since:

5.4

Nested Class Summary

Nested classes/interfaces inherited from class CompletableFuture

CompletableFuture.AsynchronousCompletionTask

Nested classes/interfaces inherited from interface Future

Future.State

Field Summary

Fields

Modifier and Type	Field	Description
(package private) boolean	cancelled
(package private) final Timeout	requestTimeout
(package private) final R	route
(package private) final Object	state
(package private) ScheduledFuture<?>	timeoutTask

Constructor Summary

Constructors

Constructor	Description
Waiter(R route, Timeout t, Object s)

Method Summary

Modifier and Type	Method	Description
PoolEntry<R,C>	get(long timeout, TimeUnit unit)

Methods inherited from class CompletableFuture

acceptEither, acceptEitherAsync, acceptEitherAsync, allOf, anyOf, applyToEither, applyToEitherAsync, applyToEitherAsync, cancel, complete, completeAsync, completeAsync, completedFuture, completedStage, completeExceptionally, completeOnTimeout, copy, defaultExecutor, delayedExecutor, delayedExecutor, exceptionally, exceptionallyAsync, exceptionallyAsync, exceptionallyCompose, exceptionallyComposeAsync, exceptionallyComposeAsync, exceptionNow, failedFuture, failedStage, get, getNow, getNumberOfDependents, handle, handleAsync, handleAsync, isCancelled, isCompletedExceptionally, isDone, join, minimalCompletionStage, newIncompleteFuture, obtrudeException, obtrudeValue, orTimeout, resultNow, runAfterBoth, runAfterBothAsync, runAfterBothAsync, runAfterEither, runAfterEitherAsync, runAfterEitherAsync, runAsync, runAsync, state, supplyAsync, supplyAsync, thenAccept, thenAcceptAsync, thenAcceptAsync, thenAcceptBoth, thenAcceptBothAsync, thenAcceptBothAsync, thenApply, thenApplyAsync, thenApplyAsync, thenCombine, thenCombineAsync, thenCombineAsync, thenCompose, thenComposeAsync, thenComposeAsync, thenRun, thenRunAsync, thenRunAsync, toCompletableFuture, toString, whenComplete, whenCompleteAsync, whenCompleteAsync

Methods inherited from class Object

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

Field Details

route

final R route

requestTimeout

final Timeout requestTimeout

state

final Object state

cancelled

volatile boolean cancelled

timeoutTask

volatile ScheduledFuture<?> timeoutTask

Constructor Details

Waiter

Waiter(R route,
 Timeout t,
 Object s)

Method Details

get

public PoolEntry<R,C> get(long timeout,
 TimeUnit unit)
                   throws InterruptedException,
ExecutionException,
TimeoutException

Specified by:

get in interface Future<PoolEntry<R, C extends ModalCloseable>>

Overrides:

get in class CompletableFuture<PoolEntry<R, C extends ModalCloseable>>

Throws:

InterruptedException

ExecutionException

TimeoutException