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

Method repeatWhen

src/main/java/io/reactivex/rxjava3/core/Maybe.java:4844–4850  ·  view source on GitHub ↗

Returns a Flowable that emits the same values as the current Maybe with the exception of an onComplete. An onComplete notification from the source will result in the emission of a void item to the Flowable provided as an argument to the {@code notifica

(@NonNull Function<? super Flowable<Object>, @NonNull ? extends Publisher<@NonNull ?>> handler)

Source from the content-addressed store, hash-verified

4842 * @see <a href="http://reactivex.io/documentation/operators/repeat.html">ReactiveX operators documentation: Repeat</a>
4843 */
4844 @BackpressureSupport(BackpressureKind.FULL)
4845 @CheckReturnValue
4846 @SchedulerSupport(SchedulerSupport.NONE)
4847 @NonNull
4848 public final Flowable<T> repeatWhen(@NonNull Function<? super Flowable<Object>, @NonNull ? extends Publisher<@NonNull ?>> handler) {
4849 return toFlowable().repeatWhen(handler);
4850 }
4851
4852 /**
4853 * Returns a {@code Maybe} that mirrors the current {@code Maybe}, resubscribing to it if it calls {@code onError}

Callers

nothing calls this directly

Calls 1

toFlowableMethod · 0.95

Tested by

no test coverage detected