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

Method toFlowable

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

Converts this Maybe into a backpressure-aware Flowable instance composing cancellation through. Backpressure: The returned

()

Source from the content-addressed store, hash-verified

4495 * @return the new {@code Flowable} instance
4496 */
4497 @SuppressWarnings("unchecked")
4498 @BackpressureSupport(BackpressureKind.FULL)
4499 @CheckReturnValue
4500 @SchedulerSupport(SchedulerSupport.NONE)
4501 @NonNull
4502 public final Flowable<T> toFlowable() {
4503 if (this instanceof FuseToFlowable) {
4504 return ((FuseToFlowable<T>)this).fuseToFlowable();
4505 }
4506 return RxJavaPlugins.onAssembly(new MaybeToFlowable<>(this));
4507 }
4508
4509 /**
4510 * Returns a {@link Future} representing the single value emitted by the current {@code Maybe}

Callers 15

repeatMethod · 0.95
repeatUntilMethod · 0.95
repeatWhenMethod · 0.95
retryMethod · 0.95
retryWhenMethod · 0.95
startWithMethod · 0.95
applyMethod · 0.45
setupMethod · 0.45
applyMethod · 0.45
setupMethod · 0.45
applyMethod · 0.45
applyMethod · 0.45

Calls 2

onAssemblyMethod · 0.95
fuseToFlowableMethod · 0.65

Tested by 15

flowableCompletable2Method · 0.36
applyMethod · 0.36
flowableMaybeFlowableMethod · 0.36
applyMethod · 0.36
observeOnDisposeMethod · 0.36
countErrorFlowableMethod · 0.36
firstOfNoneFlowableMethod · 0.36
reduceMethod · 0.36