Interface ReplayProcessor.ReplayBuffer<T>

    • Method Detail

      • error

        void error​(java.lang.Throwable ex)
      • complete

        void complete()
      • size

        int size()
      • getValues

        T[] getValues​(@NonNull T[] array)
      • isDone

        boolean isDone()
      • getError

        java.lang.Throwable getError()
      • trimHead

        void trimHead()
        Make sure an old inaccessible head value is released in a bounded buffer.