static <T> Valve<T> |
Valves.empty() |
Returns an empty Valve - instance, which report complete as soon as handler is registered.
|
default Valve<T> |
Valve.executeOn(ExecutorService executorService) |
|
default Valve<T> |
Valve.filter(Predicate<T> predicate) |
Returns a Valve consisting of the elements of this Valve that match the given predicate.
|
default <K> Valve<K> |
Valve.flatMap(Function<T,Valve<K>> mapFunction) |
Returns new Valve instance which combines all results into a single Valve.
|
static <T> Valve<T> |
Valves.from(Flow.Publisher<T> publisher) |
|
static Valve<ByteBuffer> |
Valves.from(InputStream stream,
int bufferCapacity) |
|
static Valve<ByteBuffer> |
Valves.from(InputStream stream,
int bufferCapacity,
ExecutorService executorService) |
|
static <T> Valve<T> |
Valves.from(Iterable<T> iterable) |
|
static <T> Valve<T> |
Valves.from(T... t) |
Creates a Valve instance from provided array.
|
default <K> Valve<K> |
Valve.map(Function<T,K> mapper) |
Returns a Valve consisting of the results of applying the given function to the elements of this Valve .
|
default Valve<T> |
Valve.peek(Consumer<T> action) |
Returns a Valve consisting of the elements of this Valve , additionally
performing the provided action on each element as elements are consumed from the resulting Valve .
|