Class OperatorObserveOn.ObserveOnSubscriber<T>

    • Field Summary

      Fields 
      Modifier and Type Field Description
      (package private) Subscriber<? super T> child  
      (package private) java.util.concurrent.atomic.AtomicLong counter  
      (package private) boolean delayError  
      (package private) long emitted
      Remembers how many elements have been emitted before the requests run out.
      (package private) java.lang.Throwable error
      The single exception if not null, should be written before setting finished (release) and read after reading finished (acquire).
      (package private) boolean finished  
      (package private) int limit
      The emission threshold that should trigger a replenishing request.
      (package private) NotificationLite<T> on  
      (package private) java.util.Queue<java.lang.Object> queue  
      (package private) Scheduler.Worker recursiveScheduler  
      (package private) java.util.concurrent.atomic.AtomicLong requested  
    • Field Detail

      • delayError

        final boolean delayError
      • queue

        final java.util.Queue<java.lang.Object> queue
      • limit

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

        volatile boolean finished
      • requested

        final java.util.concurrent.atomic.AtomicLong requested
      • counter

        final java.util.concurrent.atomic.AtomicLong counter
      • error

        java.lang.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 Detail

      • ObserveOnSubscriber

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