Package | Description |
---|---|
org.eclipse.microprofile.reactive.streams.operators.spi |
Modifier and Type | Method and Description |
---|---|
Graph |
Stage.Concat.getFirst()
The first graph in the stream.
|
Graph |
Stage.Coupled.getPublisher()
Get the publisher graph.
|
Graph |
Stage.Concat.getSecond()
The second graph in the stream.
|
Graph |
Stage.Coupled.getSubscriber()
Get the subscriber graph.
|
Graph |
ToGraphable.toGraph()
Convert this builder to a
Graph . |
Modifier and Type | Method and Description |
---|---|
Function<Throwable,Graph> |
Stage.OnErrorResumeWith.getFunction()
The error handler.
|
Function<?,Graph> |
Stage.FlatMap.getMapper()
The mapper function.
|
Modifier and Type | Method and Description |
---|---|
<T> CompletionStage<T> |
ReactiveStreamsEngine.buildCompletion(Graph graph)
Build a closed graph from the given stages.
|
<T,R> org.reactivestreams.Processor<T,R> |
ReactiveStreamsEngine.buildProcessor(Graph graph)
Build a
Processor from the given stages. |
<T> org.reactivestreams.Publisher<T> |
ReactiveStreamsEngine.buildPublisher(Graph graph)
Build a
Publisher from the given stages. |
<T,R> SubscriberWithCompletionStage<T,R> |
ReactiveStreamsEngine.buildSubscriber(Graph graph)
Build a
Subscriber from the given stages. |
Copyright © 2019 Eclipse Foundation. All rights reserved.