hu.akarnokd.rxjava2.subscribers.nbp

Class NbpSubscribers

java.lang.Object

hu.akarnokd.rxjava2.subscribers.nbp.NbpSubscribers

public final class NbpSubscribers
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> NbpObservable.NbpSubscriber<T>	cancelled()
static <T> NbpObservable.NbpSubscriber<T>	create(Consumer<? super T> onNext)
static <T> NbpObservable.NbpSubscriber<T>	create(Consumer<? super T> onNext, Consumer<? super java.lang.Throwable> onError)
static <T> NbpObservable.NbpSubscriber<T>	create(Consumer<? super T> onNext, Consumer<? super java.lang.Throwable> onError, java.lang.Runnable onComplete)
static <T> NbpObservable.NbpSubscriber<T>	create(Consumer<? super T> onNext, Consumer<? super java.lang.Throwable> onError, java.lang.Runnable onComplete, Consumer<? super Disposable> onStart)
static <T> NbpDisposableSubscriber<T>	createDisposable(Consumer<? super T> onNext)
static <T> NbpDisposableSubscriber<T>	createDisposable(Consumer<? super T> onNext, Consumer<? super java.lang.Throwable> onError)
static <T> NbpDisposableSubscriber<T>	createDisposable(Consumer<? super T> onNext, Consumer<? super java.lang.Throwable> onError, java.lang.Runnable onComplete)
static <T> NbpDisposableSubscriber<T>	createDisposable(Consumer<? super T> onNext, Consumer<? super java.lang.Throwable> onError, java.lang.Runnable onComplete, java.lang.Runnable onStart)
static <T> NbpObservable.NbpSubscriber<T>	empty()
static <T> NbpDisposableSubscriber<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> NbpObservable.NbpSubscriber<T> empty()

cancelled

public static <T> NbpObservable.NbpSubscriber<T> cancelled()

emptyDisposable

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

createDisposable

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

createDisposable

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

createDisposable

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

createDisposable

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

create

public static <T> NbpObservable.NbpSubscriber<T> create(Consumer<? super T> onNext)

create

public static <T> NbpObservable.NbpSubscriber<T> create(Consumer<? super T> onNext,
                                                        Consumer<? super java.lang.Throwable> onError)

create

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

create

public static <T> NbpObservable.NbpSubscriber<T> create(Consumer<? super T> onNext,
                                                        Consumer<? super java.lang.Throwable> onError,
                                                        java.lang.Runnable onComplete,
                                                        Consumer<? super Disposable> onStart)