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

Method startWith

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

Returns a Flowable which first runs the other CompletableSource then the current Flowable if the other completed normally. Ba

(@NonNull CompletableSource other)

Source from the content-addressed store, hash-verified

15761 * @since 3.0.0
15762 */
15763 @CheckReturnValue
15764 @NonNull
15765 @SchedulerSupport(SchedulerSupport.NONE)
15766 @BackpressureSupport(BackpressureKind.FULL)
15767 public final Flowable<T> startWith(@NonNull CompletableSource other) {
15768 Objects.requireNonNull(other, "other is null");
15769 return Flowable.concat(Completable.wrap(other).<T>toFlowable(), this);
15770 }
15771
15772 /**
15773 * Returns a {@code Flowable} which first runs the other {@link SingleSource}

Callers

nothing calls this directly

Calls 6

concatMethod · 0.95
wrapMethod · 0.95
wrapMethod · 0.95
wrapMethod · 0.95
concatArrayMethod · 0.95
toFlowableMethod · 0.45

Tested by

no test coverage detected