# File lib/taps/data_stream.rb, line 15
  def initialize(db, state)
    @db = db
    @state = {
      :offset => 0,
      :avg_chunksize => 0,
      :num_chunksize => 0,
      :total_chunksize => 0,
    }.merge(state)
    @state[:chunksize] ||= DEFAULT_CHUNKSIZE
    @complete = false
  end