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

Method repeatUntil

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

Re-subscribes to the current Single until the given BooleanSupplier returns true and emits the success items as a Flowable sequence. <img width="640" height="463" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/Single.repeatUntil.v3.png" alt=

(@NonNull BooleanSupplier stop)

Source from the content-addressed store, hash-verified

4355 * @since 2.0
4356 */
4357 @BackpressureSupport(BackpressureKind.FULL)
4358 @CheckReturnValue
4359 @SchedulerSupport(SchedulerSupport.NONE)
4360 @NonNull
4361 public final Flowable<T> repeatUntil(@NonNull BooleanSupplier stop) {
4362 return toFlowable().repeatUntil(stop);
4363 }
4364
4365 /**
4366 * Repeatedly re-subscribes to the current {@code Single} indefinitely if it fails with an {@code onError}.

Callers

nothing calls this directly

Calls 1

toFlowableMethod · 0.95

Tested by

no test coverage detected