Package | Description |
---|---|
org.eclipse.microprofile.reactive.streams.operators |
Modifier and Type | Interface and Description |
---|---|
interface |
ProcessorBuilder<T,R>
A builder for a
Processor . |
interface |
PublisherBuilder<T>
A builder for a
Publisher . |
Modifier and Type | Method and Description |
---|---|
<S> TransformingOperators<S> |
TransformingOperators.flatMap(Function<? super T,? extends PublisherBuilder<? extends S>> mapper)
Map the elements to publishers, and flatten so that the elements emitted by publishers produced by the
mapper function are emitted from this stream. |
<S> TransformingOperators<S> |
TransformingOperators.flatMapCompletionStage(Function<? super T,? extends CompletionStage<? extends S>> mapper)
Map the elements to
CompletionStage , and flatten so that the elements the values redeemed by each
CompletionStage are emitted from this stream. |
<S> TransformingOperators<S> |
TransformingOperators.flatMapIterable(Function<? super T,? extends Iterable<? extends S>> mapper)
Map the elements to
Iterable 's, and flatten so that the elements contained in each iterable are
emitted by this stream. |
<S> TransformingOperators<S> |
TransformingOperators.flatMapRsPublisher(Function<? super T,? extends org.reactivestreams.Publisher<? extends S>> mapper)
Map the elements to publishers, and flatten so that the elements emitted by publishers produced by the
mapper function are emitted from this stream. |
<R> TransformingOperators<R> |
TransformingOperators.map(Function<? super T,? extends R> mapper)
Map the elements emitted by this stream using the
mapper function. |
Copyright © 2019 Eclipse Foundation. All rights reserved.