Class CachedObservable.CacheState<T>

java.lang.Object
rx.internal.util.LinkedArrayList
rx.internal.operators.CachedObservable.CacheState<T>
Type Parameters:
T -
All Implemented Interfaces:
Observer<T>
Enclosing class:
CachedObservable<T>

static final class CachedObservable.CacheState<T> extends LinkedArrayList implements Observer<T>
Contains the active child producers and the values to replay.
  • Field Details

    • source

      final Observable<? extends T> source
      The source observable to connect to.
    • connection

      final SerialSubscription connection
      Holds onto the subscriber connected to source.
    • producers

      volatile CachedObservable.ReplayProducer<?>[] producers
      Guarded by connection (not this).
    • EMPTY

      static final CachedObservable.ReplayProducer<?>[] EMPTY
      The default empty array of producers.
    • nl

      final NotificationLite<T> nl
    • isConnected

      volatile boolean isConnected
      Set to true after connection.
    • sourceDone

      boolean sourceDone
      Indicates that the source has completed emitting values or the Observable was forcefully terminated.
  • Constructor Details

    • CacheState

      public CacheState(Observable<? extends T> source, int capacityHint)
  • Method Details