$pipeline = Pipeline.new("Scripts/test") { |msg| p "recv msg: #{msg}" }