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

Method startWith

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

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

(@NonNull CompletableSource other)

Source from the content-addressed store, hash-verified

4584 * @since 3.0.0
4585 */
4586 @CheckReturnValue
4587 @NonNull
4588 @SchedulerSupport(SchedulerSupport.NONE)
4589 @BackpressureSupport(BackpressureKind.FULL)
4590 public final Flowable<T> startWith(@NonNull CompletableSource other) {
4591 Objects.requireNonNull(other, "other is null");
4592 return Flowable.concat(Completable.wrap(other).<T>toFlowable(), toFlowable());
4593 }
4594
4595 /**
4596 * Returns a {@link Flowable} which first runs the other {@link SingleSource}

Callers

nothing calls this directly

Calls 8

concatMethod · 0.95
toFlowableMethod · 0.95
wrapMethod · 0.95
wrapMethod · 0.95
wrapMethod · 0.95
wrapMethod · 0.95
toObservableMethod · 0.95
concatWithMethod · 0.45

Tested by

no test coverage detected