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