私は自分自身のストリーム関数をElixirに書くことはできますか？

Question

私はこのようにそれを呼び出したときに正常に動作し、簡単なStream.unfold機能を、書かれている：

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

しかし、私は私ができるようになるラッパーを実装する方法を見つけることができていないようです私の関数を直接呼び出すこのように：私が試した何

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

は次のとおりです。

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

問題が流れていることのようだ：

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

私はこのコードを実行すると、私はエラーを取得します.take（）は配列に変換するために何らかの形で実行する必要のある別のストリームを返しています。 Stream.takeをEnum.takeに置き換えることは、ストリームをどのように実行できるかという疑問を残すトリックを行うように思えます。

Answer 1

私はそれをひっくり返したと思います。フォローコードは、私が欲しいものほとんどありません： - 私は別のSOの質問に提起した問題を

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

私は今、これを持っている唯一の問題は、出力は1つの巨大なラインに連結されていることです。