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

Method startWith

src/main/java/io/reactivex/rxjava3/core/Maybe.java:5111–5118  ·  view source on GitHub ↗

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

(@NonNull CompletableSource other)

Source from the content-addressed store, hash-verified

5109 * @since 3.0.0
5110 */
5111 @CheckReturnValue
5112 @NonNull
5113 @SchedulerSupport(SchedulerSupport.NONE)
5114 @BackpressureSupport(BackpressureKind.FULL)
5115 public final Flowable<T> startWith(@NonNull CompletableSource other) {
5116 Objects.requireNonNull(other, "other is null");
5117 return Flowable.concat(Completable.wrap(other).<T>toFlowable(), toFlowable());
5118 }
5119
5120 /**
5121 * Returns a {@link Flowable} which first runs the other {@link SingleSource}

Callers 15

startWithObservableMethod · 0.45
runCompletableErrorMethod · 0.45
justSingleJustMethod · 0.45
emptySingleJustMethod · 0.45
runSingleErrorMethod · 0.45
justMaybeJustMethod · 0.45
emptyMaybeJustMethod · 0.45
runMaybeErrorMethod · 0.45
justObservableJustMethod · 0.45
emptyObservableJustMethod · 0.45

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 15

startWithObservableMethod · 0.36
runCompletableErrorMethod · 0.36
justSingleJustMethod · 0.36
emptySingleJustMethod · 0.36
runSingleErrorMethod · 0.36
justMaybeJustMethod · 0.36
emptyMaybeJustMethod · 0.36
runMaybeErrorMethod · 0.36
justObservableJustMethod · 0.36
emptyObservableJustMethod · 0.36