Sha256: 6ffb975acf1b58e9d5db5e6138a2cf8683551f16d46ad0fe8d525faf345b22e2
Contents?: true
Size: 858 Bytes
Versions: 34
Compression:
Stored size: 858 Bytes
Contents
require 'spec_helper'
require 'flydata/query_based_sync/query_based_sync_context'
module Flydata
module QueryBasedSync
describe ResponseHandler do
include_context 'query based sync context'
let(:subject_object) { described_class.new(context) }
describe '#handle' do
subject { subject_object.handle(response) }
let(:records_for_emitting) {[
{row: {'1'=>1, '2'=>'a'}},
{row: {'1'=>2, '2'=>'b'}},
{row: {'1'=>3, '2'=>'c'}},
]}
it do
expect(subject_object).to receive(:emit_sync_records).with(records_for_emitting,
type: :update,
src_pos: response.new_source_pos.to_s,
table: 'table_1')
expect(table_1_src_pos_file).to receive(:save).with(response.new_source_pos)
subject
end
end
end
end
end
Version data entries
34 entries across 34 versions & 1 rubygems