Contents

require File.expand_path('spec/spec_helper')

describe EMDextras::Chains::SynchronousStage do
  class PasstroughSynchronousStage
    include EMDextras::Chains::SynchronousStage
    def invoke(input)
      "Got #{input}"
    end
  end

  class FailingSynchronousStage
    include EMDextras::Chains::SynchronousStage
    def invoke(input_exception)
      raise input_exception
    end
  end

  context "success:" do 
    subject { PasstroughSynchronousStage.new }

    it "should pass the return value of the invoke method to the next stage" do
      EM.run do 
        deferred = subject.todo "the input"
        deferred.should succeed_with "Got the input"
      end
    end
  end

  context "failure:" do
    subject { FailingSynchronousStage.new }

    it "should return a failed deferred" do
      EM.run do
        exception = ArgumentError.new "an exception"
        deferred = subject.todo exception
        deferred.should fail_with exception
      end
    end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
em-dextras-0.4.0	spec/em-dextras/chains/synchronous_stage_spec.rb
em-dextras-0.3.0	spec/em-dextras/chains/synchronous_stage_spec.rb
em-dextras-0.2.0	spec/em-dextras/chains/synchronous_stage_spec.rb
em-dextras-0.1.0	spec/em-dextras/chains/synchronous_stage_spec.rb
em-dextras-0.0.1	spec/em-dextras/chains/synchronous_stage_spec.rb