Class OperatorObserveOn.ObserveOnSubscriber<T>

java.lang.Object
rx.Subscriber<T>
rx.internal.operators.OperatorObserveOn.ObserveOnSubscriber<T>
All Implemented Interfaces:
Action, Action0, Function, Observer<T>, Subscription
Enclosing class:
OperatorObserveOn<T>

static final class OperatorObserveOn.ObserveOnSubscriber<T> extends Subscriber<T> implements Action0
Observe through individual queue per observer.
  • Field Details

    • child

      final Subscriber<? super T> child
    • recursiveScheduler

      final Scheduler.Worker recursiveScheduler
    • on

      final NotificationLite<T> on
    • delayError

      final boolean delayError
    • queue

      final Queue<Object> queue
    • limit

      final int limit
      The emission threshold that should trigger a replenishing request.
    • finished

      volatile boolean finished
    • requested

      final AtomicLong requested
    • counter

      final AtomicLong counter
    • error

      Throwable error
      The single exception if not null, should be written before setting finished (release) and read after reading finished (acquire).
    • emitted

      long emitted
      Remembers how many elements have been emitted before the requests run out.
  • Constructor Details

    • ObserveOnSubscriber

      public ObserveOnSubscriber(Scheduler scheduler, Subscriber<? super T> child, boolean delayError, int bufferSize)
  • Method Details