reactive-programming

    0

    1答えて

    それはパブリッシャーとサブスクライバーを持っている、とサブスクライバがパブリッシャに加入すると、加入者はまた、次のメッセージを実装として、私は、Java 9 の反応ストリームAPIを学んでいます: public class TestSubscriber<T> implements Subscriber<T> { @Override public void onComplete

    1

    1答えて

    リアクティブストリームに関しては、パブリッシャが存在し、多数のサブスクライバを持つことができます。 ただし、購読者がPublisherからメッセージを受け取ったとします。このサブスクライバ(Subs1)はメッセージを変更/変更し、変更されたメッセージを消費する他のサブスクライバ(Subs2など)に渡します。 このSubs1サブスクライバは、新しいSubs2サブスクライバにメッセージを渡すことができ

    0

    1答えて

    ReactiveCommandには、出力として整数を生成します。 public ReactiveCommand<Unit, int> Calculate { get; } このコマンドからの最新の結果は、その出力はLatestValueに格納され、ObservableAsPropertyHelper private readonly ObservableAsPropertyHelper<int

    3

    2答えて

    ドキュメントあたりとおり Flux<String> fl = Flux.just("a", "b", "c"); モノが0のストリームである: フラックス0..N要素を発することができるストリームであります..1要素: Mono<String> mn = Mono.just("hello"); 両方とも、リアクティブストリーム内のPublisherインターフェイスの実装です。 ほとんどの場

    0

    2答えて

    私はReactiveとResilientの違いを探しています。 私はいくつかの記事を通しましたが、それは私にいくらかはっきりしていますが、外交的説明とはかなり混乱しています。私は弾力性の意味理解何 は、要求の数が増加したときに同じサービスのインスタンスの数が増加した場合ということです。同様に、要求が少ない場合には減少します。したがって、インスタンスの数が増減しても、それが安定した状態にいかに簡単か

    0

    1答えて

    私はいくつかの複雑なデータでアンドロイドのfirebaseを使用しています。私は参照を保存する必要があり、私は私のzip操作、または私はRX全体を処理している方法で問題を取得しています。 Bについての情報を含む新しいA objectを作成し、についての情報を持つようにB objectを更新したいとします。 firebase操作が両方成功しているとき、私はlogcatを経由する場合はSingle<A

    1

    1答えて

    私は、非ブロッキングI/O(Spring Boot 2.0.0.M7)にSpring Webflux、Spring Data、およびProject Reactorを使用しています。 私の目標は、クライアントがいくつかの基準に基づいてエンドポイントからすべてのリソースを要求できるように株式ティッカーのようなAPIを作成し、最初のリクエスト後に作成される新しいリソースを受け取ることです。 Reacti

    0

    1答えて

    私は反応型アプローチを使用しています。私は対応するformControlオブジェクトを持っている入力フィールドを持っていますし、入力中に値をフォーマットしています - すべての入力を大文字にします。 もちろん、うまくいく - 値はビューとformControlでも更新されます。 問題は、私は、サーバーに元の値ではなくformmated値(大文字)を送信したいということです だから私は値、およびfo

    0

    1答えて

    小さなプロジェクトをRxに書き直していました。 プロジェクトの目標は、すべての NBA選手の合計レコードのリストを作成することです(レコードは給与情報+の両方が情報を統計収集:レブロンは、合計で10百万人を支払ったと35000ポイントを獲得している、3120アシストなど)。 NBAチーム(一般的なチームの記録統計情報:勝敗):NBAの開始以来、Cavsは356-200を記録していました。 だから、