Package io.reactivex.rxjava3.internal.operators.observable

Interface ObservableReplay.ReplayBuffer<T>

Type Parameters:
T - the value type
All Known Implementing Classes:
ObservableReplay.BoundedReplayBuffer, ObservableReplay.SizeAndTimeBoundReplayBuffer, ObservableReplay.SizeBoundReplayBuffer, ObservableReplay.UnboundedReplayBuffer
Enclosing class:
ObservableReplay<T>
static interface ObservableReplay.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(ObservableReplay.InnerDisposable<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 - the value to be stored in the buffer

    • error

      void error(Throwable e)
      Adds a terminal exception to the buffer.
      Parameters:
      e - the error to be stored in the buffer

    • complete

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

    • replay

      void replay(ObservableReplay.InnerDisposable<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 buffered events