Contents

require 'spec_helper'

describe LiveQA::Processor::Async do

  let(:processor) { LiveQA::Processor::Async.new }

  context 'enqueue a message' do

    before do
      allow(processor).to receive(:ensure_worker_running)
      processor.enqueue({ test: 'hello' })
    end

    it { expect(processor).to have_received(:ensure_worker_running) }
    it { expect(processor.instance_variable_get(:@queue).length).to eq(1) }
  end


end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
liveqa-1.9.3	spec/lib/liveqa/processor/async_spec.rb
liveqa-1.9.2	spec/lib/liveqa/processor/async_spec.rb
liveqa-1.9.1	spec/lib/liveqa/processor/async_spec.rb
liveqa-1.9.0	spec/lib/liveqa/processor/async_spec.rb