Contents

module Trailblazer::V2_1
  module Activity::TaskBuilder
    # every step is wrapped by this proc/decider. this is executed in the circuit as the actual task.
    # Step calls step.(options, **options, flow_options)
    # Output signal binary: true=>Right, false=>Left.
    # Passes through all subclasses of Direction.~~~~~~~~~~~~~~~~~
    def self.Binary(user_proc)
      Task.new(Trailblazer::V2_1::Option::KW( user_proc ), user_proc)
    end

    # Translates the return value of the user step into a valid signal.
    # Note that it passes through subclasses of {Signal}.
    def self.binary_signal_for(result, on_true, on_false)
      result.is_a?(Class) && result < Activity::Signal ? result : (result ? on_true : on_false)
    end

    class Task
      def initialize(task, user_proc)
        @task            = task
        @user_proc       = user_proc

        freeze
      end

      def call( (ctx, flow_options), **circuit_options )
        # Execute the user step with TRB's kw args.
        result = @task.( ctx, **circuit_options ) # circuit_options contains :exec_context.

        # Return an appropriate signal which direction to go next.
        signal = Activity::TaskBuilder.binary_signal_for( result, Activity::Right, Activity::Left )

        return signal, [ ctx, flow_options ]
      end

      def inspect
        %{#<Trailblazer::V2_1::Activity::TaskBuilder::Task user_proc=#{@user_proc}>}
      end
      alias_method :to_s, :inspect
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
trailblazer-future-2.1.0.rc1	lib/trailblazer/v2_1/activity/task_builder.rb