Package | Description |
---|---|
ratpack.exec |
The execution management.
|
ratpack.func |
General functional (i.e. Single Abstract Method) types.
|
ratpack.stream |
Support for reactive streams.
|
Modifier and Type | Method and Description |
---|---|
default <B,A> Promise<A> |
Promise.around(Factory<? extends B> before,
BiFunction<? super B,? super ExecResult<T>,? extends ExecResult<A>> after)
Facilitates capturing a value before the the promise is subscribed and using it to later augment the result.
|
default Promise<T> |
Promise.retry(int maxAttempts,
BiFunction<? super Integer,? super Throwable,Promise<Duration>> onError)
Causes
this yielding the promised value to be retried on error, after a calculated delay. |
Modifier and Type | Method and Description |
---|---|
default <V> BiFunction<I1,I2,V> |
BiFunction.andThen(Function<? super O,? extends V> transform) |
Modifier and Type | Method and Description |
---|---|
static <T,R> Promise<R> |
Streams.reduce(Publisher<T> publisher,
R seed,
BiFunction<? super R,? super T,? extends R> reducer)
Reduces the stream to a single value, by applying the given function successively.
|
default <R> Promise<R> |
TransformablePublisher.reduce(R seed,
BiFunction<? super R,? super T,? extends R> reducer)
Reduces the stream to a single value, by applying the given function successively.
|