play.libs.concurrent

Class DefaultFutures

java.lang.Object

play.libs.concurrent.DefaultFutures

All Implemented Interfaces:

Futures

public class DefaultFutures
extends java.lang.Object
implements Futures

The default implementation of the Futures trait. This provides an implementation that uses the scheduler of the application's ActorSystem.

Constructor Summary

Constructors

Constructor and Description
DefaultFutures(play.api.libs.concurrent.Futures delegate)

Method Summary

Modifier and Type	Method and Description
<A> java.util.concurrent.CompletionStage<A>	delayed(java.util.concurrent.CompletionStage<A> stage, java.time.Duration duration) Create a CompletionStage which, after a delay, will be redeemed with the result of a given supplier.
<A> java.util.concurrent.CompletionStage<A>	delayed(java.util.concurrent.CompletionStage<A> stage, long amount, java.util.concurrent.TimeUnit unit) Create a CompletionStage which, after a delay, will be redeemed with the result of a given supplier.
<A> java.util.concurrent.CompletionStage<A>	timeout(java.util.concurrent.CompletionStage<A> stage, java.time.Duration duration) An alias for futures(stage, delay, unit) that uses a java.time.Duration.
<A> java.util.concurrent.CompletionStage<A>	timeout(java.util.concurrent.CompletionStage<A> stage, long amount, java.util.concurrent.TimeUnit unit) Creates a CompletionStage that returns either the input stage, or a futures.

Methods inherited from class java.lang.Object

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

Methods inherited from interface play.libs.concurrent.Futures

delayed, sequence, sequence, timeout, timeout

Constructor Detail

DefaultFutures

@Inject
public DefaultFutures(play.api.libs.concurrent.Futures delegate)

Method Detail

timeout

public <A> java.util.concurrent.CompletionStage<A> timeout(java.util.concurrent.CompletionStage<A> stage,
                                                           long amount,
                                                           java.util.concurrent.TimeUnit unit)

Creates a CompletionStage that returns either the input stage, or a futures. Note that timeout is not the same as cancellation. Even in case of futures, the given completion stage will still complete, even though that completed value is not returned.

Specified by:

timeout in interface Futures

Type Parameters:

A - the completion's result type.

Parameters:

stage - the input completion stage that may time out.

amount - The amount (expressed with the corresponding unit).

unit - The time Unit.

Returns:

either the completed future, or a completion stage that failed with futures.

timeout

public <A> java.util.concurrent.CompletionStage<A> timeout(java.util.concurrent.CompletionStage<A> stage,
                                                           java.time.Duration duration)

An alias for futures(stage, delay, unit) that uses a java.time.Duration.

Specified by:

timeout in interface Futures

Type Parameters:

A - the completion stage that should be wrapped with a future.

Parameters:

stage - the input completion stage that may time out.

duration - The duration after which there is a timeout.

Returns:

the completion stage, or a completion stage that failed with futures.

delayed

public <A> java.util.concurrent.CompletionStage<A> delayed(java.util.concurrent.CompletionStage<A> stage,
                                                           long amount,
                                                           java.util.concurrent.TimeUnit unit)

Create a CompletionStage which, after a delay, will be redeemed with the result of a given supplier. The supplier will be called after the delay.

Specified by:

delayed in interface Futures

Type Parameters:

A - the type of the completion's result.

Parameters:

stage - the input completion stage that is delayed.

amount - The time to wait.

unit - The units to use for the amount.

Returns:

the delayed CompletionStage wrapping supplier.

delayed

public <A> java.util.concurrent.CompletionStage<A> delayed(java.util.concurrent.CompletionStage<A> stage,
                                                           java.time.Duration duration)

Create a CompletionStage which, after a delay, will be redeemed with the result of a given supplier. The supplier will be called after the delay.

Specified by:

delayed in interface Futures

Type Parameters:

A - the type of the completion's result.

Parameters:

stage - the input completion stage that is delayed.

duration - to wait.

Returns:

the delayed CompletionStage wrapping supplier.