Sha256: de5325db06943f1e26bb63281568714f0bc5373e9ad4e5028cebfdcf9ba736f8

Contents?: true

Size: 471 Bytes

Versions: 51

Compression:

Stored size: 471 Bytes

Contents

module Dynflow
  class Action::Suspended
    attr_reader :execution_plan_id, :step_id

    def initialize(action)
      @world             = action.world
      @execution_plan_id = action.execution_plan_id
      @step_id           = action.run_step_id
    end

    def event(event, future = Concurrent.future)
      @world.event execution_plan_id, step_id, event, future
    end

    def <<(event = nil)
      event event
    end

    alias_method :ask, :event
  end
end

Version data entries

51 entries across 51 versions & 1 rubygems

Version Path
dynflow-1.1.6 lib/dynflow/action/suspended.rb
dynflow-1.1.5 lib/dynflow/action/suspended.rb
dynflow-1.1.4 lib/dynflow/action/suspended.rb
dynflow-1.1.3 lib/dynflow/action/suspended.rb
dynflow-1.1.2 lib/dynflow/action/suspended.rb
dynflow-1.1.1 lib/dynflow/action/suspended.rb
dynflow-1.1.0 lib/dynflow/action/suspended.rb
dynflow-1.0.5 lib/dynflow/action/suspended.rb
dynflow-1.0.4 lib/dynflow/action/suspended.rb
dynflow-1.0.3 lib/dynflow/action/suspended.rb
dynflow-1.0.2 lib/dynflow/action/suspended.rb
dynflow-1.0.1 lib/dynflow/action/suspended.rb
dynflow-1.0.0 lib/dynflow/action/suspended.rb
dynflow-0.8.37 lib/dynflow/action/suspended.rb
dynflow-0.8.36 lib/dynflow/action/suspended.rb
dynflow-0.8.35 lib/dynflow/action/suspended.rb
dynflow-0.8.34 lib/dynflow/action/suspended.rb
dynflow-0.8.33 lib/dynflow/action/suspended.rb
dynflow-0.8.32 lib/dynflow/action/suspended.rb
dynflow-0.8.31 lib/dynflow/action/suspended.rb