module function Open3.#pipeline_rw

pipeline_rw(*cmds) -> [IO, IO, [Thread]][permalink][rdoc]
pipeline_rw(*cmds) {|first_stdin, last_stdout, wait_thrs| ... } -> ()

指定したコマンドのリストをパイプで繋いで順番に実行します。最初のコマンドの標準入力に書き込む事も最後のコマンドの標準出力を受けとる事もできます。

[PARAM] cmds:
実行するコマンドのリストを指定します。それぞれのコマンドは以下のように StringArray で指定します。 commandline にはコマンド全体(例. "nroff -man")を表す String を指定します。 options には Hash で指定します。 env には環境変数を Hash で指定します。 cmdname にはコマンド名を表す String を指定します。 1、2、3 は shell 経由で実行されます。
  1. commandline
  2. [commandline, options]
  3. [env, commandline, options]
  4. [env, cmdname, arg1, arg2, ..., options]
  5. [env, [cmdname, argv0], arg1, ..., options]
[RETURN]
ブロックを指定した場合はブロックの最後に評価された値を返します。ブロックを指定しなかった場合は最初に実行するコマンドの標準入力と最後に実行するコマンドの標準出力、実行したプロセスを待つためのスレッドの配列を配列で返します。

例:

require "open3"

Open3.pipeline_rw("sort", "cat -n") {|stdin, stdout, wait_thrs|
  stdin.puts "foo"
  stdin.puts "bar"
  stdin.puts "baz"

  # sortコマンドにEOFを送る。
  stdin.close

  # stdinに渡した文字列をsortコマンドが並べ替えたものに、catコマンド
  # が行番号を付けた文字列が表示される。
  p stdout.read   #=> "     1\tbar\n     2\tbaz\n     3\tfoo\n"
}

[SEE_ALSO] Open3.#popen3