SOC_Pipeline_Processing.rb

# Proof of Concept

class ArrayifyBehavior
  def initialize(data)
    @data = data
  end

  def self.call(data)
    new(data)
  end

  def call(behavior)
    p @data
    behavior.call(action)
  end

  def action
    Array(@data)
  end
end

class DoubleBehavior
  def initialize(data)
    @data = data
  end

  def self.call(data)
    new(data)
  end

  def call(behavior)
    p @data
    behavior.call(action)
  end

  def action
    @data + @data
  end
end

class EndOfLineBehavior
  def initialize(data)
    @data = data
  end

  def self.call(data)
    new(data)
  end

  def call(behavior)
    p @data
    behavior.call(@data)
  end
end

start_value = 123
[ArrayifyBehavior, DoubleBehavior, DoubleBehavior, EndOfLineBehavior].reduce(->(a){ a.(start_value) }) do |acc, a|
  acc.call(a)
end.call(lambda{|a|a})
# OUTPUT: =>
# 123
# [123]
# [123, 123]
# [123, 123, 123, 123]