hu.akarnokd.rxjava2.subscribers

Class Observers

java.lang.Object

hu.akarnokd.rxjava2.subscribers.Observers

public final class Observers
extends java.lang.Object

Utility class to create Observers from lambdas.

Method Summary

Modifier and Type	Method and Description
static <T> Observer<T>	create(Consumer<? super T> onNext)
static <T> Observer<T>	create(Consumer<? super T> onNext, Consumer<? super java.lang.Throwable> onError)
static <T> Observer<T>	create(Consumer<? super T> onNext, Consumer<? super java.lang.Throwable> onError, java.lang.Runnable onComplete)
static <T> Observer<T>	create(Consumer<? super T> onNext, Consumer<? super java.lang.Throwable> onError, java.lang.Runnable onComplete, java.lang.Runnable onStart)
static <T> AsyncObserver<T>	createAsync(Consumer<? super T> onNext)
static <T> AsyncObserver<T>	createAsync(Consumer<? super T> onNext, Consumer<? super java.lang.Throwable> onError)
static <T> AsyncObserver<T>	createAsync(Consumer<? super T> onNext, Consumer<? super java.lang.Throwable> onError, java.lang.Runnable onComplete)
static <T> AsyncObserver<T>	createAsync(Consumer<? super T> onNext, Consumer<? super java.lang.Throwable> onError, java.lang.Runnable onComplete, java.lang.Runnable onStart)
static <T> Observer<T>	empty()
static <T> AsyncObserver<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> Observer<T> empty()

emptyAsync

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

create

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

create

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

create

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

create

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

createAsync

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

createAsync

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

createAsync

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

createAsync

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