Contents

require 'spec_helper'

describe EventAggregator::Message do
    describe '.publish' do
		let(:message_type) {Faker::Name.name}
		let(:data)         {Faker::Name.name}
		let(:listener_class) { (Class.new { include EventAggregator::Listener }) }
		let(:callback)		 { lambda{ |data| } }

    	before(:each) do
			EventAggregator::Aggregator.class_variable_set :@@listener, Hash.new{|h, k| h[k] = []}
			@listener_one = listener_class.new
			@listener_two = listener_class.new
			
			EventAggregator::Aggregator.register(@listener_one, message_type, callback)
			EventAggregator::Aggregator.register(@listener_two, message_type+" different", callback)
		end

    	it 'should invoke message_publish on aggregator' do
    		message = EventAggregator::Message.new(message_type, data)
    		
    		expect(EventAggregator::Aggregator).to receive(:message_publish).with(message)

    		message.publish
    	end
	end

	describe 'self.new' do
		let(:message_type) {Faker::Name.name}
		let(:data)         {Faker::Name.name}
			
		it 'should require initialize data' do
			expect{EventAggregator::Message.new(message_type)}.to           raise_error
			expect{EventAggregator::Message.new(data)}.to                   raise_error
			expect{EventAggregator::Message.new(message_type, data)}.to_not raise_error
		end
		it 'should have non-nil message_type' do
			expect{EventAggregator::Message.new(nil, data)}.to raise_error
		end
		it 'should have initialize data publicly available' do
			message = EventAggregator::Message.new(message_type, data)
			
			expect(message.message_type).to equal(message_type)
			expect(message.data).to         equal(data)
		end
	end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
event_aggregator-1.0.2	spec/lib/event_aggregator/message_spec.rb
event_aggregator-1.0.1	spec/lib/event_aggregator/message_spec.rb
event_aggregator-1.0.0.pre	spec/lib/event_aggregator/message_spec.rb