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