Converts this Single into a Flowable. Backpressure: The returned Flowable honors the backpressure of the downst
()
| 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}. |
no test coverage detected