Sha256: 9aa6c654a39aea209c338860c973a546c027bd0cedd628b0876471cd7e8ff255
Contents?: true
Size: 1.65 KB
Versions: 25
Compression:
Stored size: 1.65 KB
Contents
# encoding: utf-8
require_relative 'spec_helper'
module FileWatch
describe ReadMode::Handlers::ReadFile do
let(:settings) do
Settings.from_options(
:sincedb_write_interval => 0,
:sincedb_path => File::NULL
)
end
let(:sdb_collection) { SincedbCollection.new(settings) }
let(:directory) { Pathname.new(FIXTURE_DIR) }
let(:pathname) { directory.join('uncompressed.log') }
let(:watched_file) { WatchedFile.new(pathname, PathStatClass.new(pathname), settings) }
let(:processor) { ReadMode::Processor.new(settings).add_watch(watch) }
let(:file) { DummyFileReader.new(settings.file_chunk_size, 2) }
context "simulate reading a 64KB file with a default chunk size of 32KB and a zero sincedb write interval" do
let(:watch) { double("watch", :quit? => false) }
it "calls 'sincedb_write' exactly 2 times" do
allow(FileOpener).to receive(:open).with(watched_file.path).and_return(file)
expect(sdb_collection).to receive(:sincedb_write).exactly(1).times
watched_file.activate
processor.initialize_handlers(sdb_collection, TestObserver.new)
processor.read_file(watched_file)
end
end
context "simulate reading a 64KB file with a default chunk size of 32KB and a zero sincedb write interval" do
let(:watch) { double("watch", :quit? => true) }
it "calls 'sincedb_write' exactly 0 times as shutdown is in progress" do
expect(sdb_collection).to receive(:sincedb_write).exactly(0).times
watched_file.activate
processor.initialize_handlers(sdb_collection, TestObserver.new)
processor.read_file(watched_file)
end
end
end
end
Version data entries
25 entries across 25 versions & 1 rubygems