Package io.reactivex.rxjava3.internal.operators.flowable

Class FlowableReplay.UnboundedReplayBuffer<T>

  • Type Parameters:
    T - the value type
    All Implemented Interfaces:
    FlowableReplay.ReplayBuffer<T>, java.io.Serializable, java.lang.Cloneable, java.lang.Iterable<java.lang.Object>, java.util.Collection<java.lang.Object>, java.util.List<java.lang.Object>, java.util.RandomAccess
    Enclosing class:
    FlowableReplay<T>
    static final class FlowableReplay.UnboundedReplayBuffer<T>
extends java.util.ArrayList<java.lang.Object>
implements FlowableReplay.ReplayBuffer<T>
    Holds an unbounded list of events.

    • Field Summary

      Fields 
      Modifier and Type Field Description
      private static long serialVersionUID  
      (package private) int size
      The total number of events in the buffer.

      • Fields inherited from class java.util.AbstractList

        modCount

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void complete()
      Adds a completion event to the buffer.
      void error​(java.lang.Throwable e)
      Adds a terminal exception to the buffer.
      void next​(T value)
      Adds a regular value to the buffer.
      void replay​(FlowableReplay.InnerSubscription<T> output)
      Tries to replay the buffered values to the subscriber inside the output if there is new value and requests available at the same time.

      • Methods inherited from class java.util.ArrayList

        add, add, addAll, addAll, clear, clone, contains, ensureCapacity, equals, forEach, get, hashCode, indexOf, isEmpty, iterator, lastIndexOf, listIterator, listIterator, remove, remove, removeAll, removeIf, removeRange, replaceAll, retainAll, set, size, sort, spliterator, subList, toArray, toArray, trimToSize

      • Methods inherited from class java.util.AbstractCollection

        containsAll, toString

      • Methods inherited from class java.lang.Object

        finalize, getClass, notify, notifyAll, wait, wait, wait

      • Methods inherited from interface java.util.Collection

        parallelStream, stream, toArray

      • Methods inherited from interface java.util.List

        containsAll