# 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