A light weight pipe implementation in ruby

pipe.rb

#!/usr/bin/env ruby

class PipeNode
  attr_writer :result

  def initialize(value, chain)
    @value = value
    @chain = chain
    @result = :unknown
  end

  def to_s
    "#{@value}.(#{@chain}) = #{@result}"
  end
end

class Pipe
  def self.>(value:, chain:)
    new.>(value: value, chain: chain)
  end

  def initialize
    @tree = []
  end

  def >(value: @value, chain:)
    pipe_node = PipeNode.new(value, chain)
    @tree << pipe_node
    begin
      @value = chain.class == Proc ? chain.call(value) : value.public_send(chain)
    rescue StandardError => error
      pipe_node.result = "Error: #{error.message}"
      print_tree
      raise
    end
    self
  end

  def resolve
    @value
  end

  def print_tree
    puts @tree.map(&:to_s).join(' > ')
    self
  end
end

result = Pipe
         .>(value: '10', chain: :to_i)
         .>(chain: :positive?)
         .>(chain: ->(value) { !value })
         .print_tree
         .resolve

puts
puts result.inspect
puts

result_with_error = Pipe
         .>(value: '10', chain: :to_i)
         .>(chain: :positive?)
         .>(chain: ->(value) { raise "boom" })
         .resolve