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> |
PushStream.anyMatch(Predicate<? super T> predicate) |
Close the channel and resolve the promise with true when the predicate
matches a payload.
|
PushStream<T> |
PushStream.filter(Predicate<? super T> predicate) |
Only pass events downstream when the predicate tests true.
|
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>[] |
PushStream.split(Predicate<? super T>... predicates) |
Split the events to different streams based on a predicate.
|