Class 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 Detail

      • source

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

        final SerialSubscription connection
        Holds onto the subscriber connected to source.
      • 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 Detail

      • CacheState

        public CacheState​(Observable<? extends T> source,
                          int capacityHint)