# File lib/taps/data_stream.rb, line 130 def fetch_remote(resource, headers) params = fetch_from_resource(resource, headers) encoded_data = params[:encoded_data] json = params[:json] rows = parse_encoded_data(encoded_data, json[:checksum]) @complete = rows == { } # update local state state.merge!(json[:state].merge(:chunksize => state[:chunksize])) unless @complete import_rows(rows) rows[:data].size else 0 end end