gistfile1.rb

    def cmd_receive_data
        puts "Receiving data"

        tables_with_counts, record_count = fetch_remote_tables_info

        puts "#{tables_with_counts.size} tables, #{format_number(record_count)} records"

        tables_with_counts.each do |table_name, count|
            table = db[table_name.to_sym]
            chunksize = default_chunksize

            progress = ProgressBar.new(table_name.to_s, count)

            offset = 0
            loop do
                begin
                    chunksize, rows = fetch_table_rows(table_name, chunksize, offset)
                rescue CorruptedData
                    next
                end
                break if rows == { }

                # debug stuff
                File.open("/tmp/taps.debug", "w") { |f| f.write(Marshal.dump(rows)) }

                table.import(rows[:header], rows[:data])

                progress.inc(rows[:data].size)
                offset += rows[:data].size
            end

            progress.finish
        end
    end

gistfile2.rb

irb
>> data = Marshal.load(File.read("/tmp/taps.debug"))
>> # look over the data