# File lib/taps/data_stream.rb, line 325
  def increment(row_count)
    # pop the rows we just successfully sent off the buffer
    @buffer.slice!(0, row_count)
  end