Interface OperatorReplay.ReplayBuffer<T>

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

static interface OperatorReplay.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 -
    • error

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

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

      void replay(OperatorReplay.InnerProducer<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 -