Class FlowableFromCompletable.FromCompletableObserver<T>

java.lang.Object
io.reactivex.rxjava3.internal.fuseable.AbstractEmptyQueueFuseable<T>
io.reactivex.rxjava3.internal.operators.flowable.FlowableFromCompletable.FromCompletableObserver<T>
All Implemented Interfaces:
CompletableObserver, Disposable, QueueDisposable<T>, QueueFuseable<T>, QueueSubscription<T>, SimpleQueue<T>, org.reactivestreams.Subscription
Enclosing class:
FlowableFromCompletable<T>

public static final class FlowableFromCompletable.FromCompletableObserver<T> extends AbstractEmptyQueueFuseable<T> implements CompletableObserver
  • Field Details

    • downstream

      final org.reactivestreams.Subscriber<? super T> downstream
    • upstream

      Disposable upstream
  • Constructor Details

    • FromCompletableObserver

      public FromCompletableObserver(org.reactivestreams.Subscriber<? super T> downstream)
  • Method Details