Returns a Flowable that invokes a Subscriber's Subscriber#onError onError method when the Subscriber subscribes to it. Backpressu
(@NonNull Supplier<? extends @NonNull Throwable> supplier)
| 2092 | * @see <a href="http://reactivex.io/documentation/operators/empty-never-throw.html">ReactiveX operators documentation: Throw</a> |
| 2093 | */ |
| 2094 | @CheckReturnValue |
| 2095 | @NonNull |
| 2096 | @BackpressureSupport(BackpressureKind.PASS_THROUGH) |
| 2097 | @SchedulerSupport(SchedulerSupport.NONE) |
| 2098 | public static <@NonNull T> Flowable<T> error(@NonNull Supplier<? extends @NonNull Throwable> supplier) { |
| 2099 | Objects.requireNonNull(supplier, "supplier is null"); |
| 2100 | return RxJavaPlugins.onAssembly(new FlowableError<>(supplier)); |
| 2101 | } |
| 2102 | |
| 2103 | /** |
| 2104 | * Returns a {@code Flowable} that invokes a {@link Subscriber}'s {@link Subscriber#onError onError} method when the |