Returns an Observable that invokes an Observer's Observer#onError onError method when the Observer subscribes to it. Schedu
(@NonNull Supplier<? extends @NonNull Throwable> supplier)
| 1837 | * @see <a href="http://reactivex.io/documentation/operators/empty-never-throw.html">ReactiveX operators documentation: Throw</a> |
| 1838 | */ |
| 1839 | @CheckReturnValue |
| 1840 | @NonNull |
| 1841 | @SchedulerSupport(SchedulerSupport.NONE) |
| 1842 | public static <@NonNull T> Observable<T> error(@NonNull Supplier<? extends @NonNull Throwable> supplier) { |
| 1843 | Objects.requireNonNull(supplier, "supplier is null"); |
| 1844 | return RxJavaPlugins.onAssembly(new ObservableError<>(supplier)); |
| 1845 | } |
| 1846 | |
| 1847 | /** |
| 1848 | * Returns an {@code Observable} that invokes an {@link Observer}'s {@link Observer#onError onError} method when the |