Class FlowableSwitchIfEmpty.SwitchIfEmptySubscriber<T>

java.lang.Object
io.reactivex.rxjava3.internal.operators.flowable.FlowableSwitchIfEmpty.SwitchIfEmptySubscriber<T>
All Implemented Interfaces:
FlowableSubscriber<T>, org.reactivestreams.Subscriber<T>
Enclosing class:
FlowableSwitchIfEmpty<T>

static final class FlowableSwitchIfEmpty.SwitchIfEmptySubscriber<T> extends Object implements FlowableSubscriber<T>
  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    (package private) final SubscriptionArbiter
     
    (package private) final org.reactivestreams.Subscriber<? super T>
     
    (package private) boolean
     
    (package private) final org.reactivestreams.Publisher<? extends T>
     
  • Constructor Summary

    Constructors
    Constructor
    Description
    SwitchIfEmptySubscriber(org.reactivestreams.Subscriber<? super T> actual, org.reactivestreams.Publisher<? extends T> other)
     
  • Method Summary

    Modifier and Type
    Method
    Description
    void
     
    void
     
    void
    onNext(T t)
     
    void
    onSubscribe(org.reactivestreams.Subscription s)
    Implementors of this method should make sure everything that needs to be visible in Subscriber.onNext(Object) is established before calling Subscription.request(long).

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
  • Field Details

    • downstream

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

      final org.reactivestreams.Publisher<? extends T> other
    • arbiter

      final SubscriptionArbiter arbiter
    • empty

      boolean empty
  • Constructor Details

    • SwitchIfEmptySubscriber

      SwitchIfEmptySubscriber(org.reactivestreams.Subscriber<? super T> actual, org.reactivestreams.Publisher<? extends T> other)
  • Method Details

    • onSubscribe

      public void onSubscribe(org.reactivestreams.Subscription s)
      Description copied from interface: FlowableSubscriber
      Implementors of this method should make sure everything that needs to be visible in Subscriber.onNext(Object) is established before calling Subscription.request(long). In practice this means no initialization should happen after the request() call and additional behavior is thread safe in respect to onNext.
      Specified by:
      onSubscribe in interface FlowableSubscriber<T>
      Specified by:
      onSubscribe in interface org.reactivestreams.Subscriber<T>
    • onNext

      public void onNext(T t)
      Specified by:
      onNext in interface org.reactivestreams.Subscriber<T>
    • onError

      public void onError(Throwable t)
      Specified by:
      onError in interface org.reactivestreams.Subscriber<T>
    • onComplete

      public void onComplete()
      Specified by:
      onComplete in interface org.reactivestreams.Subscriber<T>