class ProcessExecuter::Runner

def wrap_stdout_stderr(options)
  options.each_with_object({}) do |key_value, opened_pipes|
    key, value = key_value
    next unless should_wrap?(options, key, value)
    wrapped_destination = ProcessExecuter::MonitoredPipe.new(value)
    opened_pipes[key] = wrapped_destination
    options.merge!(key => wrapped_destination)
  end
end