Sha256: 1d64c746d1426351b43d6c5a9ea8f356781aea676af4977055c50861e823a7fd
Contents?: true
Size: 876 Bytes
Versions: 8
Compression:
Stored size: 876 Bytes
Contents
require 'spec_helper'
class MySubscriber < Reactor::Subscriber
attr_accessor :was_called
on_fire do
self.was_called = true
end
end
describe Reactor::Subscriber do
describe 'fire' do
subject { MySubscriber.create(event_name: :you_name_it).fire some: 'random', event: 'data' }
its(:event) { is_expected.to be_a Reactor::Event }
its('event.some') { is_expected.to eq('random') }
it 'executes block given' do
expect(subject.was_called).to be_truthy
end
end
describe 'matcher' do
before { MySubscriber.create!(event_name: '*') }
after { MySubscriber.destroy_all }
it 'can be set to star to bind to all events' do
expect_any_instance_of(MySubscriber).to receive(:fire).with(hash_including('random' => 'data', 'event' => 'this_event'))
Reactor::Event.publish(:this_event, {random: 'data'})
end
end
end
Version data entries
8 entries across 8 versions & 1 rubygems