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

Method toFlowable

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

Converts this Single into a Flowable. Backpressure: The returned Flowable honors the backpressure of the downst

()

Source from the content-addressed store, hash-verified

5404 * @return the new {@code Flowable} instance
5405 */
5406 @BackpressureSupport(BackpressureKind.FULL)
5407 @CheckReturnValue
5408 @SchedulerSupport(SchedulerSupport.NONE)
5409 @SuppressWarnings("unchecked")
5410 @NonNull
5411 public final Flowable<T> toFlowable() {
5412 if (this instanceof FuseToFlowable) {
5413 return ((FuseToFlowable<T>)this).fuseToFlowable();
5414 }
5415 return RxJavaPlugins.onAssembly(new SingleToFlowable<>(this));
5416 }
5417
5418 /**
5419 * Returns a {@link Future} representing the single value emitted by this {@code Single}.

Callers 6

repeatMethod · 0.95
repeatWhenMethod · 0.95
repeatUntilMethod · 0.95
retryMethod · 0.95
retryWhenMethod · 0.95
startWithMethod · 0.95

Calls 2

onAssemblyMethod · 0.95
fuseToFlowableMethod · 0.65

Tested by

no test coverage detected