問題タブ [fs2]

FS2でオブジェクト プール パターンを実装する最良の方法を確認しようとしています。

次のMyPrinter定義があるとします。

プリンターStream[Task, MyPrinter]のプールでバッキングを作成する最良の方法は何ですか? nストリームが終了したら、すべての基になるリソースを を呼び出して適切に解放する必要がありますreleaseResources。

おまけの質問: プリンターが何らかの理由で終了した場合、プールに新しいプリンターを作成することは可能ですか?

認識してStream[F,A]いないコードベースの一部によって消費されるために、次のより「プリミティブなストリーミング インターフェイス」に変換する必要があります。fs2

どうすればそれを行うことができますか？おそらく答えは、そのような変換は不可能であり、Java ストリーミング インターフェースを にラップするとfs2.Stream、「Java スタイル」のストリーミング インターフェースに「変換」できるようになるStreamため、トップ レベルまでバブルしなければならないということです。 someSinkおよびにパイプできますrun。

FS2 に慣れようとしているときに、Scala コレクションの Stream を使用した気の利いた再帰的な実装に出会い、FS2 で試してみたいと思いました。

これが FS2 でハングする理由は何ですか? また、同様の機能するソリューションを取得する最善の方法は何ですか?

Web サイトのロード ジェネレーターであるシステムをモデル化しようとしています。ウェブサイトには、今のところ文字列のページがあります。

Web サイトには、ランダムな時間に Web サイトの閲覧を開始するようにモデル化されたユーザーがいます。

各ユーザーはページからページへ遷移し、次のようにモデル化されます。

このシミュレーションを実行しようとしています。4 人のユーザーがランダムな間隔でこの Web サイトの閲覧を開始し、各ユーザーがランダムに 3 つのページに移動します。

出力は次のようになります。

つまり、通貨はなく、すべてのランダムスリープは厳密な順序で発生します。

これらの異なるストリーム (新しいユーザーが Web サイトを閲覧し始め、各ユーザーが行った遷移) が同時に発生するように、このプログラムを変更するにはどうすればよいですか?

ここに私の完全なプログラムがあります：

jms からデータを読み取り、それをマップして別の場所に送信したいとしましょうtoUpperCase。では、実際のメッセージング システムを で抽象化していJms[A]ますね。

ビジネス ロジック:

Freeは解釈されるので、次のようにします。

しかし、何をに渡すのfreeProcessですか？これらは何ですかsource/ sink? interpreterすべての仕事をする上での実装ではありませんか? sのことを忘れることはできませんStreamか？

ここで実際に使用する方法はFree？

私は Java で ReactiveX 拡張機能を数年間使用してきましたが、現在は scala に移行しており、多くの人が拡張機能 ScalaZ を使用して Scala でより機能的なプログラミングを実行しているのを見てきました。

ScalaZ 拡張機能を使用すること、または単に reactX を Scala に適応させることに何か違いはありますか?

そして、このブログhttps://medium.com/@luijar/the-observable-disguised-as-an-io-monad-c89042aa8f31を読んだ後、オブザーバブルはScalazのようにIOモナドとして機能していました

よろしく。

私は現在fs2-http、Scala で記述された JavaFX ライブラリのライブラリとして使用していますが、現状ではライブラリfs2-httpが非常に大きく、デスクトップ アプリケーションとして出荷するには依存関係が多すぎるため、可能な限り小さくする必要があります。機能を維持しながら、サイズとメモリ フットプリントを削減します。

Java ライブラリである Undertow を使用することにしましたが、現在、データを処理する現在の関数が既にストリームであるストリームにそのコンポーネントを変換するのに苦労しています。

これが私の質問です。この通常の Java ライブラリをストリーミング ライブラリに変換するにはどうすればよいでしょうか?