Interface FlowableReplay.ReplayBuffer<T>

Type Parameters:
T - the value type
All Known Implementing Classes:
FlowableReplay.BoundedReplayBuffer, FlowableReplay.SizeAndTimeBoundReplayBuffer, FlowableReplay.SizeBoundReplayBuffer, FlowableReplay.UnboundedReplayBuffer
Enclosing class:
FlowableReplay<T>

static interface FlowableReplay.ReplayBuffer<T>
The interface for interacting with various buffering logic.
  • Method Summary

    Modifier and Type
    Method
    Description
    void
    Adds a completion event to the buffer.
    void
    Adds a terminal exception to the buffer.
    void
    next(T value)
    Adds a regular value to the buffer.
    void
    Tries to replay the buffered values to the subscriber inside the output if there is new value and requests available at the same time.
  • Method Details

    • next

      void next(T value)
      Adds a regular value to the buffer.
      Parameters:
      value - the next value to store
    • error

      void error(Throwable e)
      Adds a terminal exception to the buffer.
      Parameters:
      e - the Throwable instance
    • complete

      void complete()
      Adds a completion event to the buffer.
    • replay

      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.
      Parameters:
      output - the receiver of the events