如何在Elixir中编写自己的流功能？

Question

我写了一个简单的Stream.unfold功能，当我这样称呼它的正常工作：

a = Stream.unfold({1,2,3}, &my_unfold_func) |> Stream.take(5) 

不过，我似乎无法找到实现包装的一种方式，让我来直接调用我的函数，例如像这样：

a = my_unfold_wrapper() |> Stream.take(5) 

我已经试过是：

def my_unfold_wrapper(), do: Stream.unfold({1,2,3}, &my_unfold_func) 

当我运行这段代码，我得到的错误：

#Stream<[enum: #Function<35.27730995/2 in Stream.unfold/2>, 
funs: [#Function<38.27730995/1 in Stream.take/2>]]> 
[Finished in 0.7s] 

这个问题似乎是该流.take（）返回另一个流，我不知何故需要执行转换为一个数组。用Enum.take替换Stream.take似乎有诀窍，这就留下了我如何执行流的问题。

Answer 1

我想我已经破解了它，后续的代码做相当多我想要的：

Foobar.my_unfold_wrapper() 
|> Stream.take(10) 
|> Stream.into(File.stream!("output.txt", [:write, :utf8])) 
|> Stream.run 

我有这个唯一的问题是现在的输出被串接到一个庞大的线 - 这是我在一个单独的SO问题都提出了一个问题。