Sha256: 21ccf0219a1254cc483bc71e6fd2169f16da36c4598676809c1a0aa136472160

Contents?: true

Size: 571 Bytes

Versions: 4

Compression:

Stored size: 571 Bytes

Contents

require 'rspec'
require 'spec_helper'

describe JobDispatch::Worker do

  Item ||= JobDispatch::Worker::Item
  Socket ||= JobDispatch::Worker::Socket

  context "with custom item class" do
    before :each do
      @klass = double('ItemClass')
      @worker = JobDispatch::Worker.new('ipc://test', item_class: @klass)
    end
    it "initialises the custom item class" do
      expect(@worker.item_class).to eq(@klass)
    end

    it "sets the custom class on the socket" do
      @worker.connect
      expect(@worker.socket.item_class).to eq(@klass)
    end
  end

end

Version data entries

4 entries across 4 versions & 1 rubygems

Version Path
job_dispatch-0.2.0 spec/job_dispatch/worker_spec.rb
job_dispatch-0.1.0 spec/job_dispatch/worker_spec.rb
job_dispatch-0.0.2 spec/job_dispatch/worker_spec.rb
job_dispatch-0.0.1 spec/job_dispatch/worker_spec.rb