Interface FlowableReplay.ReplayBuffer<T>

    • Method Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      void complete()
      Adds a completion event to the buffer.
      void error​(java.lang.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 Detail

      • next

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

        void error​(java.lang.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