Package | Description |
---|---|
org.eclipse.microprofile.reactive.streams.operators |
Modifier and Type | Interface and Description |
---|---|
interface |
CompletionRunner<T>
A builder for a closed reactive streams graph.
|
interface |
SubscriberBuilder<T,R>
A builder for a
Subscriber and its result. |
Modifier and Type | Method and Description |
---|---|
ProducesResult<Void> |
ConsumingOperators.cancel()
Cancels the stream as soon as it is run.
|
<R,A> ProducesResult<R> |
ConsumingOperators.collect(Collector<? super T,A,R> collector)
Collect the elements emitted by this stream using the given
Collector . |
<R> ProducesResult<R> |
ConsumingOperators.collect(Supplier<R> supplier,
BiConsumer<R,? super T> accumulator)
Collect the elements emitted by this stream using a
Collector built from the given
supplier and accumulator . |
ProducesResult<Optional<T>> |
ConsumingOperators.findFirst()
Find the first element emitted by the
Publisher , and return it in a
CompletionStage . |
ProducesResult<Void> |
ConsumingOperators.forEach(Consumer<? super T> action)
Performs an action for each element on this stream.
|
ProducesResult<Void> |
ConsumingOperators.ignore()
Ignores each element of this stream.
|
ProducesResult<Optional<T>> |
ConsumingOperators.reduce(BinaryOperator<T> accumulator)
Perform a reduction on the elements of this stream, using the provided accumulation function.
|
ProducesResult<T> |
ConsumingOperators.reduce(T identity,
BinaryOperator<T> accumulator)
Perform a reduction on the elements of this stream, using the provided identity value and the accumulation
function.
|
ProducesResult<Void> |
ConnectingOperators.to(org.reactivestreams.Subscriber<? super T> subscriber)
Connect the outlet of the
Publisher built by this builder to the given Subscriber . |
<R> ProducesResult<R> |
ConnectingOperators.to(SubscriberBuilder<? super T,? extends R> subscriberBuilder)
Connect the outlet of this stream to the given
SubscriberBuilder graph. |
ProducesResult<List<T>> |
ConsumingOperators.toList()
Collect the elements emitted by this stream into a
List . |
Copyright © 2019 Eclipse Foundation. All rights reserved.