spec/lib/broker_spec.rb in firehose-0.0.16 vs spec/lib/broker_spec.rb in firehose-0.1.0

- old
+ new

@@ -1,30 +1,30 @@ -require 'spec_helper' +# require 'spec_helper' -describe Firehose::Broker do - include EM::TestHelper +# describe Firehose::Broker do +# include EM::TestHelper - let(:broker) { Firehose::Broker.new } +# let(:broker) { Firehose::Broker.new } - it "should unsubscibe consumers and remove them from the collection" do - stats = nil +# it "should unsubscibe consumers and remove them from the collection" do +# stats = nil - em do - broker.consumer('1').subscribe_to('/the-channel') - broker.consumer('2').subscribe_to('/the-channel') - broker.consumer('2').subscribe_to('/a-channel') +# em do +# broker.consumer('1').subscribe_to('/the-channel') +# broker.consumer('2').subscribe_to('/the-channel') +# broker.consumer('2').subscribe_to('/a-channel') - em.add_timer(1) do - stats = broker.stats - broker.stop - em.stop - end - end +# em.add_timer(1) do +# stats = broker.stats +# broker.stop +# em.stop +# end +# end - stats.should == { - '1' => {'subscriptions' => ['/the-channel'] }, - '2' => {'subscriptions' => ['/the-channel', '/a-channel']} - } +# stats.should == { +# '1' => {'subscriptions' => ['/the-channel'] }, +# '2' => {'subscriptions' => ['/the-channel', '/a-channel']} +# } - broker.stats.should == {} - end -end +# broker.stats.should == {} +# end +# end \ No newline at end of file