Class FlowableRepeatWhen.WhenSourceSubscriber<T,U>

java.lang.Object
java.lang.Number
java.util.concurrent.atomic.AtomicInteger
io.reactivex.rxjava3.internal.subscriptions.SubscriptionArbiter
io.reactivex.rxjava3.internal.operators.flowable.FlowableRepeatWhen.WhenSourceSubscriber<T,U>
All Implemented Interfaces:
FlowableSubscriber<T>, Serializable, org.reactivestreams.Subscriber<T>, org.reactivestreams.Subscription
Direct Known Subclasses:
FlowableRepeatWhen.RepeatWhenSubscriber, FlowableRetryWhen.RetryWhenSubscriber
Enclosing class:
FlowableRepeatWhen<T>

abstract static class FlowableRepeatWhen.WhenSourceSubscriber<T,U> extends SubscriptionArbiter implements FlowableSubscriber<T>
  • Field Details

    • serialVersionUID

      private static final long serialVersionUID
      See Also:
    • downstream

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

      protected final FlowableProcessor<U> processor
    • receiver

      protected final org.reactivestreams.Subscription receiver
    • produced

      private long produced
  • Constructor Details

    • WhenSourceSubscriber

      WhenSourceSubscriber(org.reactivestreams.Subscriber<? super T> actual, FlowableProcessor<U> processor, org.reactivestreams.Subscription receiver)
  • 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>
    • onNext

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

      protected final void again(U signal)
    • cancel

      public final void cancel()
      Specified by:
      cancel in interface org.reactivestreams.Subscription
      Overrides:
      cancel in class SubscriptionArbiter