public final class NbpObservers
extends java.lang.Object
| 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() |
public static <T> NbpObserver<T> empty()
public static <T> NbpAsyncObserver<T> emptyAsync()
public static <T> NbpObserver<T> create(Consumer<? super T> onNext)
public static <T> NbpObserver<T> create(Consumer<? super T> onNext, Consumer<? super java.lang.Throwable> onError)
public static <T> NbpObserver<T> create(Consumer<? super T> onNext, Consumer<? super java.lang.Throwable> onError, java.lang.Runnable onComplete)
public static <T> NbpObserver<T> create(Consumer<? super T> onNext, Consumer<? super java.lang.Throwable> onError, java.lang.Runnable onComplete, java.lang.Runnable onStart)
public static <T> NbpAsyncObserver<T> createAsync(Consumer<? super T> onNext)
public static <T> NbpAsyncObserver<T> createAsync(Consumer<? super T> onNext, Consumer<? super java.lang.Throwable> onError)
public static <T> NbpAsyncObserver<T> createAsync(Consumer<? super T> onNext, Consumer<? super java.lang.Throwable> onError, java.lang.Runnable onComplete)
public static <T> NbpAsyncObserver<T> createAsync(Consumer<? super T> onNext, Consumer<? super java.lang.Throwable> onError, java.lang.Runnable onComplete, java.lang.Runnable onStart)