class Toys::Utils::Exec::Executor

def capture_stream_thread(key) 

def capture_stream_thread(key)
  stream = make_out_pipe(key)
  @join_threads << ::Thread.new do
    begin
      @captures[key] = stream.read
    ensure
      stream.close
    end
  end
end