Sha256: 497f64a43ee0cf01c566b1582a9181438fde0ee129c5d17854257d72affaf6c5

Contents?: true

Size: 859 Bytes

Versions: 1

Compression:

Stored size: 859 Bytes

Contents

require 'spec_helper'

describe Cascadence::Runner do
  let(:runner) { Cascadence::Runner.instance }
  let(:task) do
    Class.new do
      def call
        sleep 2
        puts "thread exiting"
        return 13
      end
    end
  end
  before :each do
    @tasks = 1.upto(7).map { |a| task.new }
  end
  context "public api" do
    describe "#run_tasks" do
      let(:doitfaggot) { runner.run_tasks @tasks }
      before(:each) { Cascadence.config.parallel = true }
      it "should be okay" do
        expect { doitfaggot }.not_to raise_error
      end
      after(:each) { Cascadence.config.parallel = false }
    end
  end
  context "private" do
    describe "#_run_parallel" do
      let(:doitfaggot) { runner.send("_run_parallel", @tasks ) }    
      it "should be okay" do
        expect { doitfaggot }.not_to raise_error
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version Path
cascadence-0.3.0 spec/cascadence/runner_spec.rb