pipeline.rb

require "net/http"
require "json"


class Pipeline < BasicObject
  def self.start
    new
  end

  def initialize
    @prev = nil
  end

  def >(right)
    if right.respond_to?(:call)
      @prev = right.call(@prev)
    else
      @prev = right
    end
    self
  end

  def method_missing(name, *args)
    @prev = @prev.__send__(name, *args)
    self
  end
end

Pipeline.start
  |>>"https://api.github.com/repos/ruby/ruby"
  |>> URI.:parse
  |>> Net::HTTP.:get
  |>> JSON.:parse
  |> fetch("stargazers_count")
  |>> "Ruby has %d stars".:%
  |>> self.:puts