Class FlowableConcatMap.BaseConcatMapSubscriber<T,R>

java.lang.Object
java.lang.Number
java.util.concurrent.atomic.AtomicInteger
io.reactivex.rxjava3.internal.operators.flowable.FlowableConcatMap.BaseConcatMapSubscriber<T,R>
All Implemented Interfaces:
FlowableSubscriber<T>, FlowableConcatMap.ConcatMapSupport<R>, Serializable, org.reactivestreams.Subscriber<T>, org.reactivestreams.Subscription
Direct Known Subclasses:
FlowableConcatMap.ConcatMapDelayed, FlowableConcatMap.ConcatMapImmediate
Enclosing class:
FlowableConcatMap<T,R>

abstract static class FlowableConcatMap.BaseConcatMapSubscriber<T,R> extends AtomicInteger implements FlowableSubscriber<T>, FlowableConcatMap.ConcatMapSupport<R>, org.reactivestreams.Subscription
  • Field Details

    • serialVersionUID

      private static final long serialVersionUID
      See Also:
    • inner

    • mapper

      final Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper
    • prefetch

      final int prefetch
    • limit

      final int limit
    • upstream

      org.reactivestreams.Subscription upstream
    • consumed

      int consumed
    • queue

      SimpleQueue<T> queue
    • done

      volatile boolean done
    • cancelled

      volatile boolean cancelled
    • errors

      final AtomicThrowable errors
    • active

      volatile boolean active
    • sourceMode

      int sourceMode
  • Constructor Details

    • BaseConcatMapSubscriber

      BaseConcatMapSubscriber(Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper, int prefetch)
  • Method Details

    • onSubscribe

      public final 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>
    • drain

      abstract void drain()
    • subscribeActual

      abstract void subscribeActual()
    • onNext

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

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

      public final void innerComplete()
      Specified by:
      innerComplete in interface FlowableConcatMap.ConcatMapSupport<T>