public final class Subscribers
extends java.lang.Object
| Modifier and Type | Method and Description |
|---|---|
static <T> org.reactivestreams.Subscriber<T> |
cancelled() |
static <T> org.reactivestreams.Subscriber<T> |
create(Consumer<? super T> onNext) |
static <T> org.reactivestreams.Subscriber<T> |
create(Consumer<? super T> onNext,
Consumer<? super java.lang.Throwable> onError) |
static <T> org.reactivestreams.Subscriber<T> |
create(Consumer<? super T> onNext,
Consumer<? super java.lang.Throwable> onError,
java.lang.Runnable onComplete) |
static <T> org.reactivestreams.Subscriber<T> |
create(Consumer<? super T> onNext,
Consumer<? super java.lang.Throwable> onError,
java.lang.Runnable onComplete,
Consumer<? super org.reactivestreams.Subscription> onStart) |
static <T> DisposableSubscriber<T> |
createDisposable(Consumer<? super T> onNext) |
static <T> DisposableSubscriber<T> |
createDisposable(Consumer<? super T> onNext,
Consumer<? super java.lang.Throwable> onError) |
static <T> DisposableSubscriber<T> |
createDisposable(Consumer<? super T> onNext,
Consumer<? super java.lang.Throwable> onError,
java.lang.Runnable onComplete) |
static <T> DisposableSubscriber<T> |
createDisposable(Consumer<? super T> onNext,
Consumer<? super java.lang.Throwable> onError,
java.lang.Runnable onComplete,
java.lang.Runnable onStart) |
static <T> org.reactivestreams.Subscriber<T> |
empty() |
static <T> DisposableSubscriber<T> |
emptyDisposable() |
public static <T> org.reactivestreams.Subscriber<T> empty()
public static <T> org.reactivestreams.Subscriber<T> cancelled()
public static <T> DisposableSubscriber<T> emptyDisposable()
public static <T> DisposableSubscriber<T> createDisposable(Consumer<? super T> onNext)
public static <T> DisposableSubscriber<T> createDisposable(Consumer<? super T> onNext, Consumer<? super java.lang.Throwable> onError)
public static <T> DisposableSubscriber<T> createDisposable(Consumer<? super T> onNext, Consumer<? super java.lang.Throwable> onError, java.lang.Runnable onComplete)
public static <T> DisposableSubscriber<T> createDisposable(Consumer<? super T> onNext, Consumer<? super java.lang.Throwable> onError, java.lang.Runnable onComplete, java.lang.Runnable onStart)
public static <T> org.reactivestreams.Subscriber<T> create(Consumer<? super T> onNext)
public static <T> org.reactivestreams.Subscriber<T> create(Consumer<? super T> onNext, Consumer<? super java.lang.Throwable> onError)
public static <T> org.reactivestreams.Subscriber<T> create(Consumer<? super T> onNext, Consumer<? super java.lang.Throwable> onError, java.lang.Runnable onComplete)