# 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