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 do
      MySubscriber.create!(event_name: '*')
      Reactor.enable_test_mode_subscriber Reactor::Subscriber
    end

    after do
      Reactor.disable_test_mode_subscriber Reactor::Subscriber
      MySubscriber.destroy_all
    end

    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

7 entries across 7 versions & 1 rubygems

Version	Path
reactor-0.18.0	spec/models/subscriber_spec.rb
reactor-0.17.0	spec/models/subscriber_spec.rb
reactor-0.16.1	spec/models/subscriber_spec.rb
reactor-0.16.0	spec/models/subscriber_spec.rb
reactor-0.15.1	spec/models/subscriber_spec.rb
reactor-0.15.0	spec/models/subscriber_spec.rb
reactor-0.14.0	spec/models/subscriber_spec.rb