hu.akarnokd.rxjava2.subscribers.nbp

Class NbpObservers

java.lang.Object

hu.akarnokd.rxjava2.subscribers.nbp.NbpObservers

public final class NbpObservers
extends java.lang.Object

Utility class to create Observers from lambdas.

Method Summary

Modifier and Type	Method and Description
static <T> NbpObserver<T>	create(Consumer<? super T> onNext)
static <T> NbpObserver<T>	create(Consumer<? super T> onNext, Consumer<? super java.lang.Throwable> onError)
static <T> NbpObserver<T>	create(Consumer<? super T> onNext, Consumer<? super java.lang.Throwable> onError, java.lang.Runnable onComplete)
static <T> NbpObserver<T>	create(Consumer<? super T> onNext, Consumer<? super java.lang.Throwable> onError, java.lang.Runnable onComplete, java.lang.Runnable onStart)
static <T> NbpAsyncObserver<T>	createAsync(Consumer<? super T> onNext)
static <T> NbpAsyncObserver<T>	createAsync(Consumer<? super T> onNext, Consumer<? super java.lang.Throwable> onError)
static <T> NbpAsyncObserver<T>	createAsync(Consumer<? super T> onNext, Consumer<? super java.lang.Throwable> onError, java.lang.Runnable onComplete)
static <T> NbpAsyncObserver<T>	createAsync(Consumer<? super T> onNext, Consumer<? super java.lang.Throwable> onError, java.lang.Runnable onComplete, java.lang.Runnable onStart)
static <T> NbpObserver<T>	empty()
static <T> NbpAsyncObserver<T>	emptyAsync()

Methods inherited from class java.lang.Object

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

Method Detail

empty

public static <T> NbpObserver<T> empty()

emptyAsync

public static <T> NbpAsyncObserver<T> emptyAsync()

create

public static <T> NbpObserver<T> create(Consumer<? super T> onNext)

create

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

create

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

create

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

createAsync

public static <T> NbpAsyncObserver<T> createAsync(Consumer<? super T> onNext)

createAsync

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

createAsync

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

createAsync

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