Converts this Maybe into a backpressure-aware Flowable instance composing cancellation through. Backpressure: The returned
()
| 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} |