Lines Matching refs:cmds
427 def pipeline_rw(*cmds, &block)
428 if Hash === cmds.last
429 opts = cmds.pop.dup
441 pipeline_run(cmds, opts, [in_r, out_w], [in_w, out_r], &block)
483 def pipeline_r(*cmds, &block)
484 if Hash === cmds.last
485 opts = cmds.pop.dup
493 pipeline_run(cmds, opts, [out_w], [out_r], &block)
525 def pipeline_w(*cmds, &block)
526 if Hash === cmds.last
527 opts = cmds.pop.dup
536 pipeline_run(cmds, opts, [in_r], [in_w], &block)
584 def pipeline_start(*cmds, &block)
585 if Hash === cmds.last
586 opts = cmds.pop.dup
592 pipeline_run(cmds, opts, [], [], &block)
594 ts, = pipeline_run(cmds, opts, [], [])
652 def pipeline(*cmds)
653 if Hash === cmds.last
654 opts = cmds.pop.dup
659 pipeline_run(cmds, opts, [], []) {|ts|
665 def pipeline_run(cmds, pipeline_opts, child_io, parent_io) # :nodoc:
666 if cmds.empty?
676 cmds.each_with_index {|cmd, i|
692 if i != cmds.length - 1