Sha256: 207f9b369b3d5bb0bde69c86bb447b673c908e7fc4be5dc7b9e8b6208f60b243
Contents?: true
Size: 656 Bytes
Versions: 26
Compression:
Stored size: 656 Bytes
Contents
require File.dirname(__FILE__) + '/base'
require 'taps/data_stream'
describe Taps::DataStream do
before do
@db = mock('db')
end
it "increments the offset" do
stream = Taps::DataStream.new(@db, :table_name => 'test_table', :chunksize => 100)
stream.state[:offset].should == 0
stream.increment(100)
stream.state[:offset].should == 100
end
it "marks the stream complete if no rows are fetched" do
stream = Taps::DataStream.new(@db, :table_name => 'test_table', :chunksize => 100)
stream.stubs(:fetch_rows).returns({})
stream.complete?.should.be.false
stream.fetch
stream.complete?.should.be.true
end
end
Version data entries
26 entries across 26 versions & 6 rubygems