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

Method repeatWhen

src/main/java/io/reactivex/rxjava3/core/Single.java:4332–4338  ·  view source on GitHub ↗

Re-subscribes to the current Single if the Publisher returned by the handler function signals a value in response to a value signaled through the Flowable the handler receives. <img width="640" height="1480" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-oper

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

Source from the content-addressed store, hash-verified

4330 * @since 2.0
4331 */
4332 @BackpressureSupport(BackpressureKind.FULL)
4333 @CheckReturnValue
4334 @SchedulerSupport(SchedulerSupport.NONE)
4335 @NonNull
4336 public final Flowable<T> repeatWhen(@NonNull Function<? super Flowable<Object>, @NonNull ? extends Publisher<@NonNull ?>> handler) {
4337 return toFlowable().repeatWhen(handler);
4338 }
4339
4340 /**
4341 * Re-subscribes to the current {@code Single} until the given {@link BooleanSupplier} returns {@code true}

Callers

nothing calls this directly

Calls 1

toFlowableMethod · 0.95

Tested by

no test coverage detected