Contents

require "wisper"
require "dry/transaction/step_failure"

module Dry
  module Transaction
    # @api private
    class Step
      include Wisper::Publisher

      attr_reader :step_name
      attr_reader :operation
      attr_reader :call_args

      def initialize(step_name, operation, call_args = [])
        @step_name = step_name
        @operation = operation
        @call_args = call_args
      end

      def with_call_args(*call_args)
        self.class.new(step_name, operation, call_args)
      end

      def call(input)
        args = call_args + [input]
        result = operation.call(*args)

        result.fmap { |value|
          broadcast :"#{step_name}_success", value
          value
        }.or { |value|
          broadcast :"#{step_name}_failure", *args, value
          Left(StepFailure.new(step_name, value))
        }
      end

      def arity
        operation.arity
      end
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
dry-transaction-0.5.0	lib/dry/transaction/step.rb
dry-transaction-0.4.0	lib/dry/transaction/step.rb