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

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
    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(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.

  • 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