# 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