Contents

module EMDextras::Chains::SynchronousStage
  def invoke(input)
    raise NotImplementedError.new("You must implement #invoke.")
  end

  def todo(input)
    begin 
      value = invoke(input)
      EMDextras::Chains::Deferrables.succeeded value
    rescue  => exception
      EMDextras::Chains::Deferrables.failed exception
    end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
em-dextras-0.4.0	lib/em-dextras/chains/synchronous_stage.rb
em-dextras-0.3.0	lib/em-dextras/chains/synchronous_stage.rb
em-dextras-0.2.0	lib/em-dextras/chains/synchronous_stage.rb
em-dextras-0.1.0	lib/em-dextras/chains/synchronous_stage.rb
em-dextras-0.0.1	lib/em-dextras/chains/synchronous_stage.rb