Package | Description |
---|---|
reactor.bus.selector |
Selectors provide a way to register components to react to given key data. |
reactor.fn |
This package contains the foundational abstractions on which Reactor's functional and reactive components are
built.
|
reactor.groovy.ext | |
reactor.groovy.support | |
reactor.rx |
Streams are reactive components derived from Reactive Extensions and implementing Reactive Streams specification.
|
reactor.rx.action.conditional | |
reactor.rx.action.error | |
reactor.rx.action.filter |
Modifier and Type | Class and Description |
---|---|
class |
ClassSelector
Implementation of
Selector that uses Class.isAssignableFrom(Class) to determine a match. |
class |
JsonPathSelector |
class |
ObjectSelector<K,T>
Selector implementation that uses the Object.hashCode() and Object.equals(Object)
methods of the internal object to determine a match. |
class |
PredicateSelector
|
class |
RegexSelector
A
Selector implementation based on the given regular expression. |
class |
UriPathSelector
A
Selector implementation based on a UriPathTemplate . |
class |
UriSelector
A
Selector implementation that matches on various components of a full URI. |
Modifier and Type | Method and Description |
---|---|
static Selector |
Selectors.predicate(Predicate<Object> predicate)
|
static PredicateSelector |
PredicateSelector.predicateSelector(Predicate<Object> predicate)
|
Constructor and Description |
---|
PredicateSelector(Predicate<Object> object) |
Modifier and Type | Method and Description |
---|---|
static <T> Predicate<T> |
Predicates.always()
Deprecated.
Returns a Predicate which always evaluates to true.
|
static <T> Predicate<T> |
Predicates.and(Predicate<? super T>... predicates)
Deprecated.
Returns a Predicate which evaluates to true only if all the provided predicates evaluate to
true.
|
static <T> Predicate<T> |
Predicates.negate(Predicate<? super T> p)
Deprecated.
Returns a Predicate which negates the given Predicate.
|
static <T> Predicate<T> |
Predicates.never()
Deprecated.
Returns a Predicate which always evaluates to false.
|
static <T> Predicate<T> |
Predicates.or(Predicate<? super T> p1,
Predicate<? super T> p2)
Deprecated.
Returns a Predicate which evaluates to true if either this predicate or the provided
predicate
evaluate to true.
|
static <T> Predicate<T> |
Predicates.xor(Predicate<? super T> p1,
Predicate<? super T> p2)
Deprecated.
Returns a Predicate which evaluates to true if either both Predicate Predicates
return true or neither of them do.
|
Modifier and Type | Method and Description |
---|---|
static <T> Predicate<T> |
Predicates.and(Predicate<? super T>... predicates)
Deprecated.
Returns a Predicate which evaluates to true only if all the provided predicates evaluate to
true.
|
static <T> Supplier<T> |
Suppliers.filter(Iterable<T> src,
Predicate<T> predicate)
Deprecated.
Filter the given
Iterable using the given Predicate so that calls to the return Supplier.get() will provide only items from the original collection which pass the predicate
test. |
static <T> Predicate<T> |
Predicates.negate(Predicate<? super T> p)
Deprecated.
Returns a Predicate which negates the given Predicate.
|
static <T> Predicate<T> |
Predicates.or(Predicate<? super T> p1,
Predicate<? super T> p2)
Deprecated.
Returns a Predicate which evaluates to true if either this predicate or the provided
predicate
evaluate to true.
|
static <T> Predicate<T> |
Predicates.or(Predicate<? super T> p1,
Predicate<? super T> p2)
Deprecated.
Returns a Predicate which evaluates to true if either this predicate or the provided
predicate
evaluate to true.
|
static <T> Supplier<T> |
Suppliers.supplyWhile(T obj,
Predicate<T> predicate)
Deprecated.
Supply the given object to callers only as long as the given
Predicate returns true. |
static <T> Predicate<T> |
Predicates.xor(Predicate<? super T> p1,
Predicate<? super T> p2)
Deprecated.
Returns a Predicate which evaluates to true if either both Predicate Predicates
return true or neither of them do.
|
static <T> Predicate<T> |
Predicates.xor(Predicate<? super T> p1,
Predicate<? super T> p2)
Deprecated.
Returns a Predicate which evaluates to true if either both Predicate Predicates
return true or neither of them do.
|
Modifier and Type | Method and Description |
---|---|
static <T> Stream<T> |
StreamExtensions.and(Promise<T> selfType,
Predicate<T> other) |
static <T> Stream<T> |
StreamExtensions.and(Stream<T> selfType,
Predicate<T> other) |
Modifier and Type | Class and Description |
---|---|
class |
ClosurePredicate<V> |
Modifier and Type | Method and Description |
---|---|
Stream<Boolean> |
Stream.exists(Predicate<? super O> predicate)
Create a new
Stream that emits true when any value satisfies a predicate
and false otherwise |
Stream<O> |
Stream.filter(Predicate<? super O> p)
Evaluate each accepted value against the given
Predicate . |
<E> Stream<O> |
Stream.ignoreError(Predicate<? super Throwable> ignorePredicate)
Connect an error-proof action based on the given predicate matching the current error.
|
Stream<O> |
Stream.retry(int numRetries,
Predicate<Throwable> retryMatcher)
Create a new
Stream which will re-subscribe its oldest parent-child stream pair. |
Stream<O> |
Stream.retry(Predicate<Throwable> retryMatcher)
Create a new
Stream which will re-subscribe its oldest parent-child stream pair. |
Stream<O> |
Stream.skipWhile(long max,
Predicate<O> limitMatcher)
Create a new
Stream that will NOT signal next elements while is true or
up to times. |
Stream<O> |
Stream.skipWhile(Predicate<O> limitMatcher)
Create a new
Stream that will NOT signal next elements while is true. |
Stream<O> |
Stream.takeWhile(Predicate<O> limitMatcher)
Create a new
Stream that will signal next elements while is true. |
Constructor and Description |
---|
ExistsAction(Predicate<? super T> predicate) |
Constructor and Description |
---|
IgnoreErrorAction(Predicate<? super Throwable> ignorePredicate) |
RetryAction(Dispatcher dispatcher,
int numRetries,
Predicate<Throwable> predicate,
org.reactivestreams.Publisher<? extends T> parentStream) |
Modifier and Type | Field and Description |
---|---|
static Predicate<Boolean> |
FilterAction.simplePredicate |
Constructor and Description |
---|
FilterAction(Predicate<? super T> p) |
SkipAction(Predicate<T> predicate,
long limit) |
TakeWhileAction(Predicate<T> predicate) |
Copyright © 2016. All rights reserved.