stream - 将 STDOUT 流式传输到文件

Question

我正在尝试将 STDOUT/ 流式传输:stdio到使用Task. 我已经尝试了管道的变化，Enum.each以及将每个函数放在父进程中，这些解决方案都没有在编译时产生任何错误。另一方面，他们也没有写入我的文件。这是我目前对它应该如何工作的最佳猜测：

defmodule OutputWriter do
  def start do
    Task.start(fn -> stream() end)
  end

  defp stream do
    Enum.each(IO.stream(:stdio, :line), fn line -> File.write(Path.join("test", "output.txt"), line) end)
  end
end

标签： streamelixir