| Package | Description |
|---|---|
| org.eclipse.microprofile.reactive.streams.operators |
| Modifier and Type | Method and Description |
|---|---|
CompletionSubscriber<T,R> |
SubscriberBuilder.build()
Build this stream, using the first
ReactiveStreamsEngine found by the ServiceLoader. |
CompletionSubscriber<T,R> |
SubscriberBuilder.build(ReactiveStreamsEngine engine)
Build this stream, using the supplied
ReactiveStreamsEngine. |
static <T,R> CompletionSubscriber<T,R> |
CompletionSubscriber.of(org.reactivestreams.Subscriber<T> subscriber,
CompletionStage<R> completion)
Create a
CompletionSubscriber by combining the given subscriber and completion stage. |
Copyright © 2019 Eclipse Foundation. All rights reserved.