Записать поток Поток текста

Question

У меня есть приложение Elixir, где я создаю внешний процесс, используя Porcelain. Созданный процесс STDOUT доступен мне как поток текста как proc.out (в форме #Function<59.89908360/2 in Stream.unfold/2>).

Я могу распечатать содержимое потока по строкам, используя IO.stream/2, но я бы прямо хотел это сделать, используя Logger.info. Это то, что она в настоящее время выглядит следующим образом:

proc = Porcelain.spawn("node", ["/path/to/node/server.js"], [out: :stream]) 
stream = proc.out 
Enum.into(stream, IO.stream(:stdio, :line)) 

В настоящее время я пытался:

• [out: Logger.info]
• Enum.into(proc.out, Logger.info)

Answer 1

Enum.map/2 и Enum.each/2 как решить мою проблему итерация потока линий и применения Logger.info. Но, как @dogbert pointed out, each может быть быстрее и лучше подходит в данном случае:

Enum.each(stream, &Logger.info/1)