stream - 万能药:可观察到的

Question

Elixir 流提供了可迭代，但我找不到任何有关可观察的信息(Google 在这里没有帮助)。如果有人能为我指出同样的资源，我将不胜感激。

Answer 1

您可以结合 Stream 和 Enum 来编写可观察样式的代码。下面是一个以可观察方式编写的回显服务器的示例:

IO.stream(:stdio, :line) 
|> Stream.map(&String.upcase/1)
|> Enum.each(&IO.write(&1))

基本上，对于发送到标准输入的每一行，它都会被转换为大写，然后打印回标准输出。这是一个简单的示例，但要点是您已经可以通过 Stream 和 Enum 获得编写可观察对象所需的一切。