Package rx.internal.operators

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
    complete()
    Adds a completion event to the buffer
    void
    error(Throwable e)
    Adds a terminal exception to the buffer
    void
    next(T value)
    Adds a regular value to the buffer.
    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.

  • 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 -