Sha256: 22f6144807bfa5cde7c6b92f1a852bc7c355fb583b86c45471bb5394c162bbe2

Contents?: true

Size: 734 Bytes

Versions: 3

Compression:

Stored size: 734 Bytes

Contents

require 'spec_helper'

#class Waffle::Transports::Redis
#end

describe Waffle::Transports::Redis do
  subject{Waffle::Transports::Redis.new(config)}

  let(:config){Waffle::Config::Node.new({})}
  let(:redis){mock(:redis)}
  let(:subscription){mock(:subscription)}

  before do
    subject.stub(:db => redis)
  end

  describe '.publish' do
    before{redis.should_receive(:publish).with('events', '"message"')}
    specify{subject.publish('events', 'message')}
  end

  describe '.subscribe' do
    before do
      redis.should_receive(:subscribe).with('events').and_yield(subscription)
      subscription.should_receive(:message).and_yield('event', '{"data":"message"}')
    end
    specify{subject.subscribe('events'){}}
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version Path
waffle-0.6.0 spec/waffle/transports/redis_spec.rb
waffle-0.5.1 spec/waffle/transports/redis_spec.rb
waffle-0.5.0 spec/waffle/transports/redis_spec.rb