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 Promise<T> |
Promise.route(Predicate<? super T> predicate,
Action<? super T> action)
Allows the promised value to be handled specially if it meets the given predicate, instead of being handled by the promise subscriber.
|
Modifier and Type | Method and Description |
---|---|
static <T> Predicate<T> |
Predicate.from(Predicate<T> predicate)
Creates a predicate from a JDK predicate.
|
static <T> Predicate<T> |
Predicate.fromGuava(Predicate<T> predicate)
Creates a predicate from a Guava predicate.
|
Modifier and Type | Method and Description |
---|---|
default TransformablePublisher<T> |
TransformablePublisher.filter(Predicate<T> filter)
|
static <T> TransformablePublisher<T> |
Streams.filter(org.reactivestreams.Publisher<T> input,
Predicate<T> filter)
Returns a publisher that filters items from the given input stream by applying the given filter predicate.
|