hu.akarnokd.rxjava2.subscribers

Class Subscribers

java.lang.Object

hu.akarnokd.rxjava2.subscribers.Subscribers

public final class Subscribers
extends java.lang.Object

Utility class to construct various resource-holding and disposable Subscribers from lambdas.

Method Summary

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()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

empty

public static <T> org.reactivestreams.Subscriber<T> empty()

cancelled

public static <T> org.reactivestreams.Subscriber<T> cancelled()

emptyDisposable

public static <T> DisposableSubscriber<T> emptyDisposable()

createDisposable

public static <T> DisposableSubscriber<T> createDisposable(Consumer<? super T> onNext)

createDisposable

public static <T> DisposableSubscriber<T> createDisposable(Consumer<? super T> onNext,
                                                           Consumer<? super java.lang.Throwable> onError)

createDisposable

public static <T> DisposableSubscriber<T> createDisposable(Consumer<? super T> onNext,
                                                           Consumer<? super java.lang.Throwable> onError,
                                                           java.lang.Runnable onComplete)

createDisposable

public static <T> DisposableSubscriber<T> createDisposable(Consumer<? super T> onNext,
                                                           Consumer<? super java.lang.Throwable> onError,
                                                           java.lang.Runnable onComplete,
                                                           java.lang.Runnable onStart)

create

public static <T> org.reactivestreams.Subscriber<T> create(Consumer<? super T> onNext)

create

public static <T> org.reactivestreams.Subscriber<T> create(Consumer<? super T> onNext,
                                                           Consumer<? super java.lang.Throwable> onError)

create

public static <T> org.reactivestreams.Subscriber<T> create(Consumer<? super T> onNext,
                                                           Consumer<? super java.lang.Throwable> onError,
                                                           java.lang.Runnable onComplete)

create

public 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)