MCPcopy Index your code
hub / github.com/ReactiveX/RxJava / error

Method error

src/main/java/io/reactivex/rxjava3/core/Flowable.java:2094–2101  ·  view source on GitHub ↗

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)

Source from the content-addressed store, hash-verified

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

Callers 15

assertErrorMethod · 0.95
applyMethod · 0.95
fromFlowableErrorMethod · 0.95
fromFutureMethod · 0.95
applyMethod · 0.95
flowableSubscribe0Method · 0.95
flowableSubscribe1Method · 0.95
flowableForEachWhileMethod · 0.95

Calls 2

onAssemblyMethod · 0.95
justSupplierMethod · 0.95

Tested by 15

assertErrorMethod · 0.76
applyMethod · 0.76
fromFlowableErrorMethod · 0.76
fromFutureMethod · 0.76
applyMethod · 0.76
flowableSubscribe0Method · 0.76
flowableSubscribe1Method · 0.76
flowableForEachWhileMethod · 0.76