問題タブ [fs2]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
scala - fs2.Stream[IO, Something] が take(1) で返されない
測定値の fs2.Stream を返す関数があります。
テストフラグを渡さない限り、通常は無限のストリームです。テストフラグを渡した場合は、1 つの値を出力して停止する必要があります。
無限ストリームは正常に機能します。それは私にすべての測定値を無限に与えます。実際、テスト ストリームは最初の測定値のみを提供し、それ以上は提供しません。私が抱えている問題は、この最後の測定後にストリームが返されないことです。永久にブロックします。私は何を間違っていますか？
注: 本質的なコードを抽象化したと思いますが、詳細については、私のプロジェクトをご覧ください: https://github.com/jkransen/fijnstof/blob/ZIO/src/main/scala/nl/kransen/fijnstof /Main.scala
scala - Scala fs2: fromFreeC と Algebra は何をしますか?
fs2 ストリーム操作の実装に入ると、そこでよく目にしfromFreeC、Algebra使用されます。
正確fromFreeCには何をAlgebraしますか？なぜ、いつ必要なのですか？
evalこれは、効果を評価して効果的なストリームを返すfs2 ストリーム操作の例です。