Class FlowableFromObservable.SubscriberObserver<T>

  • All Implemented Interfaces:
    Observer<T>, org.reactivestreams.Subscription
    Enclosing class:
    FlowableFromObservable<T>

    static final class FlowableFromObservable.SubscriberObserver<T>
    extends java.lang.Object
    implements Observer<T>, org.reactivestreams.Subscription
    • Field Detail

      • downstream

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

      • SubscriberObserver

        SubscriberObserver​(org.reactivestreams.Subscriber<? super T> s)