public final class FlowableBlockingSubscribe extends Object
Modifier and Type | Method and Description |
---|---|
static <T> void |
subscribe(org.reactivestreams.Publisher<? extends T> o)
Runs the source observable to a terminal event, ignoring any values and rethrowing any exception.
|
static <T> void |
subscribe(org.reactivestreams.Publisher<? extends T> o,
Consumer<? super T> onNext,
Consumer<? super Throwable> onError,
Action onComplete)
Subscribes to the source and calls the given actions on the current thread.
|
static <T> void |
subscribe(org.reactivestreams.Publisher<? extends T> o,
Consumer<? super T> onNext,
Consumer<? super Throwable> onError,
Action onComplete,
int bufferSize)
Subscribes to the source and calls the given actions on the current thread.
|
static <T> void |
subscribe(org.reactivestreams.Publisher<? extends T> o,
org.reactivestreams.Subscriber<? super T> subscriber)
Subscribes to the source and calls the Subscriber methods on the current thread.
|
public static <T> void subscribe(org.reactivestreams.Publisher<? extends T> o, org.reactivestreams.Subscriber<? super T> subscriber)
T
- the value typeo
- the source publisher
The cancellation and backpressure is composed through.subscriber
- the subscriber to forward events and calls to in the current threadpublic static <T> void subscribe(org.reactivestreams.Publisher<? extends T> o)
T
- the value typeo
- the source publisherpublic static <T> void subscribe(org.reactivestreams.Publisher<? extends T> o, Consumer<? super T> onNext, Consumer<? super Throwable> onError, Action onComplete)
T
- the value typeo
- the source publisheronNext
- the callback action for each source valueonError
- the callback action for an error eventonComplete
- the callback action for the completion event.public static <T> void subscribe(org.reactivestreams.Publisher<? extends T> o, Consumer<? super T> onNext, Consumer<? super Throwable> onError, Action onComplete, int bufferSize)
T
- the value typeo
- the source publisheronNext
- the callback action for each source valueonError
- the callback action for an error eventonComplete
- the callback action for the completion event.bufferSize
- the number of elements to prefetch from the source PublisherCopyright © 2019. All rights reserved.