Sha256: caf774e36a84de46154e59d3e026e5e90e7bd2439ac57612c98da80a77e574fd
Contents?: true
Size: 1.79 KB
Versions: 21
Compression:
Stored size: 1.79 KB
Contents
# encoding: utf-8
require "logstash/event_dispatcher"
require "logstash/plugins/hooks_registry"
describe LogStash::Plugins::HooksRegistry do
class DummyEmitter
attr_reader :dispatcher
def initialize
@dispatcher = LogStash::EventDispatcher.new(self)
end
def do_work
dispatcher.fire(:do_work)
end
end
class DummyListener
def initialize
@work = false
end
def do_work(emitter = nil)
@work = true
end
def work?
@work
end
end
subject { described_class.new }
let(:emitter) { DummyEmitter.new }
let(:listener) { DummyListener.new }
it "allow to register an emitter" do
expect { subject.register_emitter(emitter.class, emitter.dispatcher) }.to change { subject.emitters_count }.by(1)
end
it "allow to remove an emitter" do
subject.register_emitter(emitter.class, emitter.dispatcher)
expect { subject.remove_emitter(emitter.class)}.to change { subject.emitters_count }.by(-1)
end
it "allow to register hooks to emitters" do
expect { subject.register_hooks(emitter.class, listener) }.to change { subject.hooks_count }.by(1)
expect { subject.register_hooks(emitter.class, listener) }.to change { subject.hooks_count(emitter.class) }.by(1)
end
it "verifies if a hook is registered to a specific emitter scope" do
subject.register_hooks(emitter.class, listener)
expect(subject.registered_hook?(emitter.class, listener.class)).to be_truthy
expect(subject.registered_hook?(Class.new, listener.class)).to be_falsey
end
it "link the emitter class to the listener" do
subject.register_emitter(emitter.class, emitter.dispatcher)
subject.register_hooks(emitter.class, listener)
expect(listener.work?).to be_falsey
emitter.do_work
expect(listener.work?).to be_truthy
end
end
Version data entries
21 entries across 21 versions & 1 rubygems