Sha256: d4800baa27cee222aa80876328775f0cf394dad30f712e938bff7a774838c615

Contents?: true

Size: 592 Bytes

Versions: 4

Compression:

Stored size: 592 Bytes

Contents

require 'spec_helper'
module Queuel
  module Base
    describe Queue do
      let(:client) { double "Client" }
      let(:queue_name) { double "some_queue" }
      subject { described_class.new client, queue_name }

      its(:thread_count) { should == 1 }

      it "fails on non-impleneted push" do
        expect { subject.push("") }.to raise_error NotImplementedError
      end

      describe "polling" do
        it "delegates polling to a new poller" do
          Poller.any_instance.should_receive(:poll).once
          subject.receive { |m| }
        end
      end
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version Path
queuel-0.3.1 spec/lib/queuel/base/queue_spec.rb
queuel-0.3.0 spec/lib/queuel/base/queue_spec.rb
queuel-0.2.0 spec/lib/queuel/base/queue_spec.rb
queuel-0.1.0 spec/lib/queuel/base/queue_spec.rb