# Next is tube. Tube processes piped data. A example tube recieve # Integer value then increase amount of the value. # class Triple < Datapipes::Tube def run(data) if accept? data [data, data, data] else data end end def accept?(data) data.is_a? Integer and data > 3 end end