public static class F.Promise<A>
extends java.lang.Object
A.| Constructor and Description |
|---|
F.Promise(scala.concurrent.Future<A> future)
Deprecated.
Since 2.2. Use
wrap(Future) instead. |
| Modifier and Type | Method and Description |
|---|---|
static <A> F.Promise<A> |
delayed(F.Function0<A> function,
long delay,
java.util.concurrent.TimeUnit unit)
Create a Promise which, after a delay, will be redeemed with the result of a
given function.
|
static <A> F.Promise<A> |
delayed(F.Function0<A> function,
long delay,
java.util.concurrent.TimeUnit unit,
scala.concurrent.ExecutionContext ec)
Create a Promise which, after a delay, will be redeemed with the result of a
given function.
|
<B> F.Promise<B> |
flatMap(F.Function<A,F.Promise<B>> function)
Maps the result of this promise to a promise for a result of type
B, and flattens that to be
a single promise for B. |
<B> F.Promise<B> |
flatMap(F.Function<A,F.Promise<B>> function,
scala.concurrent.ExecutionContext ec)
Maps the result of this promise to a promise for a result of type
B, and flattens that to be
a single promise for B. |
A |
get()
Deprecated.
Since 2.2. Use
get(long, TimeUnit) or get(long) instead. |
A |
get(long timeout)
Awaits for the promise to get the result.
|
A |
get(java.lang.Long timeout)
Deprecated.
Since 2.2. Use {
get(long) instead. |
A |
get(long timeout,
java.util.concurrent.TimeUnit unit)
Awaits for the promise to get the result.
|
A |
get(java.lang.Long timeout,
java.util.concurrent.TimeUnit unit)
Deprecated.
Since 2.2. Use
get(long, TimeUnit) instead. |
scala.concurrent.Future<A> |
getWrappedPromise()
Deprecated.
Since 2.2. Use
wrapped() instead. |
<B> F.Promise<B> |
map(F.Function<A,B> function)
Maps this promise to a promise of type
B. |
<B> F.Promise<B> |
map(F.Function<A,B> function,
scala.concurrent.ExecutionContext ec)
Maps this promise to a promise of type
B. |
void |
onFailure(F.Callback<java.lang.Throwable> action)
Perform the given
action callback if the promise encounters an exception. |
void |
onFailure(F.Callback<java.lang.Throwable> action,
scala.concurrent.ExecutionContext ec)
Perform the given
action callback if the promise encounters an exception. |
void |
onRedeem(F.Callback<A> action)
Perform the given
action callback when the Promise is redeemed. |
void |
onRedeem(F.Callback<A> action,
scala.concurrent.ExecutionContext ec)
Perform the given
action callback when the Promise is redeemed. |
<B> F.Promise<F.Either<A,B>> |
or(F.Promise<B> another)
combines the current promise with
another promise using `or` |
static <A> F.Promise<A> |
promise(F.Function0<A> function)
Create a Promise which will be redeemed with the result of a given function.
|
static <A> F.Promise<A> |
promise(F.Function0<A> function,
scala.concurrent.ExecutionContext ec)
Create a Promise which will be redeemed with the result of a given Function0.
|
static <A> F.Promise<A> |
pure(A a)
Create a new pure promise, that is, a promise with a constant value from the start.
|
F.Promise<A> |
recover(F.Function<java.lang.Throwable,A> function)
Wraps this promise in a promise that will handle exceptions thrown by this Promise.
|
F.Promise<A> |
recover(F.Function<java.lang.Throwable,A> function,
scala.concurrent.ExecutionContext ec)
Wraps this promise in a promise that will handle exceptions thrown by this Promise.
|
static <A> F.Promise<java.util.List<A>> |
sequence(scala.concurrent.ExecutionContext ec,
F.Promise<? extends A>... promises)
Combine the given promises into a single promise for the list of results.
|
static <A> F.Promise<java.util.List<A>> |
sequence(F.Promise<? extends A>... promises)
Combine the given promises into a single promise for the list of results.
|
static <A> F.Promise<java.util.List<A>> |
sequence(java.lang.Iterable<F.Promise<? extends A>> promises)
Combine the given promises into a single promise for the list of results.
|
static <A> F.Promise<java.util.List<A>> |
sequence(java.lang.Iterable<F.Promise<? extends A>> promises,
scala.concurrent.ExecutionContext ec)
Combine the given promises into a single promise for the list of results.
|
static <A> F.Promise<A> |
throwing(java.lang.Throwable throwable)
Create a new promise throwing an exception.
|
static F.Promise<scala.Unit> |
timeout()
Deprecated.
Since 2.2. Use
timeout(long) or timeout(long, TimeUnit) instead. |
static <A> F.Promise<A> |
timeout(A message,
long delay)
Create a Promise that is redeemed after a timeout.
|
static <A> F.Promise<A> |
timeout(A message,
java.lang.Long delay)
Deprecated.
Since 2.2. Use
timeout(Object, long) instead. |
static <A> F.Promise<A> |
timeout(A message,
long delay,
java.util.concurrent.TimeUnit unit)
Create a Promise that is redeemed after a timeout.
|
static <A> F.Promise<A> |
timeout(A message,
java.lang.Long delay,
java.util.concurrent.TimeUnit unit)
Deprecated.
Since 2.2. Use
timeout(Object, long, TimeUnit) instead. |
static <A> F.Promise<scala.Unit> |
timeout(long delay)
Create a Promise timer that throws a TimeoutException after a
given timeout.
|
static <A> F.Promise<scala.Unit> |
timeout(long delay,
java.util.concurrent.TimeUnit unit)
Create a Promise timer that throws a TimeoutException after a
given timeout.
|
static <A> F.Promise<java.util.List<A>> |
waitAll(F.Promise<? extends A>... promises)
Deprecated.
Since 2.1. Use
#sequence(Promise...) instead. |
static <A> F.Promise<java.util.List<A>> |
waitAll(java.lang.Iterable<F.Promise<? extends A>> promises)
Deprecated.
Since 2.1. Use
sequence(Iterable) instead. |
static <A> F.Promise<A> |
wrap(scala.concurrent.Future<A> future)
Creates a Promise that wraps a Scala Future.
|
scala.concurrent.Future<A> |
wrapped()
Gets the Scala Future wrapped by this Promise.
|
<B> F.Promise<F.Tuple<A,B>> |
zip(F.Promise<B> another)
Zips the values of this promise with
another, and creates a new promise holding the tuple of their results |
@Deprecated public F.Promise(scala.concurrent.Future<A> future)
wrap(Future) instead.future - The Scala Future to wrappublic static <A> F.Promise<A> wrap(scala.concurrent.Future<A> future)
future - The Scala Future to wrappublic static <A> F.Promise<java.util.List<A>> sequence(F.Promise<? extends A>... promises)
promises - The promises to combinepublic static <A> F.Promise<java.util.List<A>> sequence(scala.concurrent.ExecutionContext ec, F.Promise<? extends A>... promises)
ec - Used to execute the sequencing operations.promises - The promises to combine@Deprecated public static <A> F.Promise<java.util.List<A>> waitAll(F.Promise<? extends A>... promises)
#sequence(Promise...) instead.promises - The promises to combinepublic static <A> F.Promise<A> timeout(A message, long delay, java.util.concurrent.TimeUnit unit)
message - The message to use to redeem the Promise.delay - The delay (expressed with the corresponding unit).unit - The Unit.@Deprecated public static <A> F.Promise<A> timeout(A message, java.lang.Long delay, java.util.concurrent.TimeUnit unit)
timeout(Object, long, TimeUnit) instead.message - The message to use to redeem the Promise.delay - The delay (expressed with the corresponding unit).unit - The Unit.@Deprecated public static F.Promise<scala.Unit> timeout() throws java.util.concurrent.TimeoutException
java.util.concurrent.TimeoutExceptionpublic static <A> F.Promise<A> timeout(A message, long delay)
message - The message to use to redeem the Promise.delay - The delay expressed in milliseconds.@Deprecated public static <A> F.Promise<A> timeout(A message, java.lang.Long delay)
timeout(Object, long) instead.message - The message to use to redeem the Promise.delay - The delay expressed in milliseconds.public static <A> F.Promise<scala.Unit> timeout(long delay)
delay - The delay expressed in milliseconds.public static <A> F.Promise<scala.Unit> timeout(long delay, java.util.concurrent.TimeUnit unit)
delay - The delay (expressed with the corresponding unit).unit - The Unit.public static <A> F.Promise<java.util.List<A>> sequence(java.lang.Iterable<F.Promise<? extends A>> promises)
promises - The promises to combinepublic static <A> F.Promise<java.util.List<A>> sequence(java.lang.Iterable<F.Promise<? extends A>> promises, scala.concurrent.ExecutionContext ec)
promises - The promises to combineec - Used to execute the sequencing operations.@Deprecated public static <A> F.Promise<java.util.List<A>> waitAll(java.lang.Iterable<F.Promise<? extends A>> promises)
sequence(Iterable) instead.promises - The promises to combinepublic static <A> F.Promise<A> pure(A a)
a - the value for the promisepublic static <A> F.Promise<A> throwing(java.lang.Throwable throwable)
throwable - Value to throwpublic static <A> F.Promise<A> promise(F.Function0<A> function)
function - Used to fulfill the Promise.public static <A> F.Promise<A> promise(F.Function0<A> function, scala.concurrent.ExecutionContext ec)
function - Used to fulfill the Promise.ec - The ExecutionContext to run the function in.public static <A> F.Promise<A> delayed(F.Function0<A> function, long delay, java.util.concurrent.TimeUnit unit)
function - The function to call to fulfill the Promise.delay - The time to wait.unit - The units to use for the delay.public static <A> F.Promise<A> delayed(F.Function0<A> function, long delay, java.util.concurrent.TimeUnit unit, scala.concurrent.ExecutionContext ec)
function - The function to call to fulfill the Promise.delay - The time to wait.unit - The units to use for the delay.ec - The ExecutionContext to run the Function0 in.@Deprecated public A get()
@Deprecated public A get(java.lang.Long timeout, java.util.concurrent.TimeUnit unit)
get(long, TimeUnit) instead.timeout - A user defined timeoutunit - timeout for timeoutpublic A get(long timeout, java.util.concurrent.TimeUnit unit)
timeout - A user defined timeoutunit - timeout for timeout@Deprecated public A get(java.lang.Long timeout)
get(long) instead.timeout - A user defined timeout in millisecondspublic A get(long timeout)
timeout - A user defined timeout in millisecondspublic <B> F.Promise<F.Either<A,B>> or(F.Promise<B> another)
another promise using `or`another - public void onRedeem(F.Callback<A> action)
action callback when the Promise is redeemed.
The callback will be run in the default execution context.action - The action to perform.public void onRedeem(F.Callback<A> action, scala.concurrent.ExecutionContext ec)
action callback when the Promise is redeemed.action - The action to perform.ec - The ExecutionContext to execute the action in.public <B> F.Promise<B> map(F.Function<A,B> function)
B. The function function is applied as
soon as the promise is redeemed.
The function will be run in the default execution context.function - The function to map A to B.A to B.public <B> F.Promise<B> map(F.Function<A,B> function, scala.concurrent.ExecutionContext ec)
B. The function function is applied as
soon as the promise is redeemed.function - The function to map A to B.ec - The ExecutionContext to execute the function in.A to B.public F.Promise<A> recover(F.Function<java.lang.Throwable,A> function)
function - The function to handle the exception. This may, for example, convert the exception into something
of type T, or it may throw another exception, or it may do some other handling.function throws an
exception.public F.Promise<A> recover(F.Function<java.lang.Throwable,A> function, scala.concurrent.ExecutionContext ec)
function - The function to handle the exception. This may, for example, convert the exception into something
of type T, or it may throw another exception, or it may do some other handling.ec - The ExecutionContext to execute the function in.function throws an
exception.public void onFailure(F.Callback<java.lang.Throwable> action)
action callback if the promise encounters an exception.
This action will be run in the default exceution context.action - The action to perform.public void onFailure(F.Callback<java.lang.Throwable> action, scala.concurrent.ExecutionContext ec)
action callback if the promise encounters an exception.action - The action to perform.ec - The ExecutionContext to execute the callback in.public <B> F.Promise<B> flatMap(F.Function<A,F.Promise<B>> function)
B, and flattens that to be
a single promise for B.
The function will be run in the default execution context.function - The function to map A to a promise for B.Bpublic <B> F.Promise<B> flatMap(F.Function<A,F.Promise<B>> function, scala.concurrent.ExecutionContext ec)
B, and flattens that to be
a single promise for B.function - The function to map A to a promise for B.ec - The ExecutionContext to execute the function in.Bpublic <B> F.Promise<F.Tuple<A,B>> zip(F.Promise<B> another)
another, and creates a new promise holding the tuple of their resultsanother - public scala.concurrent.Future<A> wrapped()