問題タブ [project-reactor]

次のプロジェクトで Akka と Reactor のどちらを使用するかを検討しています。最も重要な問題の 1 つは、選択する将来のフレームワークがリモーティングを提供するかどうかです。私が見たように、Akka は私たちが望んでいた方法でこれを提供します。

残念ながら、GitHub wiki では、TCP サーバー/クライアントのセクションが空白であり、それに関する他の情報はまだ見つかりませんでした。

リアクターはリモーティングを提供しますか?

Chronicleベースの永続性を使用するようにReactorを構成しようとしていますが、ドキュメントでこれに関する情報を見つけることができません。2 つの方法があります。

1. サポートする独自のディスパッチャーを作成するPersistentQueue
2. EventBatcherそのようなキューで使用して、Reactorインスタンスをラップします

どちらのオプションが優れていますか? それとも、私が見落としていた別の解決策があるのでしょうか?

Reactor を使い始めましたが、最初のイベントで問題が発生しています :D

github の例に従って、「hello world」を書き込もうとしましたが、成功しませんでした...

何が問題ですか？

コード：

出力：

Reactor 2.0.0.M1 を使用しており、Stream. ブール演算の結果に応じて、いずれかのストリームを続行したいと考えています。これは関数で可能であるように見えますotherwise()が、その使用方法は明確ではありません。

マイ ストリームは次のようになります。

が trueの場合を処理するには、ストリームを続行するためにo.isValid()呼び出すだけでよいと理解しています。.map()

o.isValid()が falseの場合を処理するために、代替.otherwise()ストリームにアクセスできます。

しかし、or()類似の方法はないようです。そのため、両方のストリームを完全に流動的な方法で構成することはできないようです。

私が思いつくことができる最高のものは、次のようなものです：

それは本当に最善の方法ですか？