問題タブ [cyclops-react]

私はsimple-reactを使用しています。

内部LazyFutureStreamでは、エンティティを永続化したいと考えています。

これは正しいです ？すべてのスレッドのセッション ファクトリの作成をスキップする方法はありますか。

また、上記では、フォークしたいだけで、参加したくありません。それでいいですか？

私はサイクロプス反応を非同期再試行で使い始めています。私はまだそれで少し迷っています。

SimpleReact を使用してサーバーからのタイムアウトをシミュレートしていますが、次のようなタイムアウトを受け取ることはありません。

そこに欠けているものは何ですか？

サイズに基づいてキューから要素をバッチ処理するためにcyclops-reactを使用しようとしていますが、時間にも基づいているため、要素がない場合はブロックされません

機能が期待したものではないか、何か間違ったことをしている可能性があります

完全なコード (Groovy) は、プロデューサーが別のスレッドにある場合に次のようになります。

出力は次のとおりです。

しかし、提供される要素間の遅延は10秒ですが、バッチ処理は0.5秒ごとであるため、各バッチで1つの要素を期待していました

また、非同期ストリーム(Groovyコード)で試しました:

繰り返しますが、2 秒ごとにのみバッチ処理し、バッチのタイムアウトが 0.5 秒であっても、バッチごとに 2 つの要素を待機することがあります。

非未来非遅延ストリームで 3 番目の実験を行いましたが、今回はうまくいきました。

結果：

将来のストリームを使用すると、バッチ処理の動作が間違っているように見えるのはなぜですか?

IOExceptionCyclops React の「Try with Resources」ブロックで、カスタム例外タイプにマップしたいと思います。私はこれをJavaslangでも試しましたが、すべての例外を同じように扱うため、柔軟性が低いようです。

コード例:

これはよりエレガントな方法で行うことができますか? それとも意味がなく、戻ったほうがいいTry<String, IOException>ですか？

免責事項: 私は Cyclops React ライブラリと関数型プログラミング全般を使用する初心者であるため、深刻な概念上の誤解がある可能性があります。