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)
| 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} |
nothing calls this directly
no test coverage detected