Package | Description |
---|---|
org.osgi.util.promise |
Promise Package Version 1.1.
|
org.osgi.util.pushstream |
Push Stream Package Version 1.0.
|
Modifier and Type | Field and Description |
---|---|
private Predicate<? super T> |
DeferredPromiseImpl.Filter.predicate |
Modifier and Type | Method and Description |
---|---|
Promise<T> |
Promise.filter(Predicate<? super T> predicate)
Filter the value of this Promise.
|
Promise<T> |
FailedPromiseImpl.filter(Predicate<? super T> predicate)
Filter the value of this Promise.
|
Promise<T> |
PromiseImpl.filter(Predicate<? super T> predicate)
Filter the value of this Promise.
|
Constructor and Description |
---|
Filter(PromiseImpl<T> promise,
Predicate<? super T> predicate) |
Modifier and Type | Method and Description |
---|---|
Promise<java.lang.Boolean> |
AbstractPushStreamImpl.allMatch(Predicate<? super T> predicate) |
Promise<java.lang.Boolean> |
PushStream.allMatch(Predicate<? super T> predicate)
Closes the channel and resolve the promise with false when the predicate
does not matches a pay load.
|
Promise<java.lang.Boolean> |
AbstractPushStreamImpl.anyMatch(Predicate<? super T> predicate) |
Promise<java.lang.Boolean> |
PushStream.anyMatch(Predicate<? super T> predicate)
Close the channel and resolve the promise with true when the predicate
matches a payload.
|
PushStream<T> |
AbstractPushStreamImpl.filter(Predicate<? super T> predicate) |
PushStream<T> |
PushStream.filter(Predicate<? super T> predicate)
Only pass events downstream when the predicate tests true.
|
Promise<java.lang.Boolean> |
AbstractPushStreamImpl.noneMatch(Predicate<? super T> predicate) |
Promise<java.lang.Boolean> |
PushStream.noneMatch(Predicate<? super T> predicate)
Closes the channel and resolve the promise with false when the predicate
matches any pay load.
|
PushStream<T>[] |
AbstractPushStreamImpl.split(Predicate<? super T>... predicates) |
PushStream<T>[] |
PushStream.split(Predicate<? super T>... predicates)
Split the events to different streams based on a predicate.
|