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