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.