Sha256: b22ec2e50b1cad30758449d9ac4e0b3049b07d54ab66fe196bbebf6c811196bd
Contents?: true
Size: 945 Bytes
Versions: 17
Compression:
Stored size: 945 Bytes
Contents
require "spec_helper"
describe Shamu::Events::InMemory::Service do
let( :service ) { scorpion.new Shamu::Events::InMemory::Service }
let( :message ) { Shamu::Events::Message.new }
describe "#publish" do
it "adds message to channel" do
expect do
service.publish( "spec", message )
end.to change { service.channel_stats( "spec" )[ :queue_size ] }
end
it "serializes the message" do
expect( service ).to receive( :serialize ).and_call_original
service.publish( "spec", message )
end
end
describe "#subscribe" do
it "receives a message" do
expect do |b|
service.subscribe "spec", &b
service.publish "spec", message
service.dispatch
end.to yield_control
end
it "deserializes the message" do
expect( service ).to receive( :deserialize ).and_call_original
service.publish "spec", message
service.dispatch
end
end
end
Version data entries
17 entries across 17 versions & 1 rubygems