reactive

1熱

1答えて

リアクティブプログラミングでスレッドを回避し、オブジェクト間で非同期メッセージをやり取りする代わりに、スケーラビリティをどのように管理するのですか？新しいインスタンスが必要なときはどうすれば決定できますか？これを透過的に管理するいくつかのAPIはありますか？

1熱

1答えて

Shinyのリアクティブ関数を編集するための戦略 'data'はベクトル型でなければならない 'NULL'エラー

目的：非メトリックな多次元スケーリングの応力プロットを表示する光沢のあるアプリケーションを作成しようとしています。（2）ポイント構成のggplot、（3）ポイント構成をプロットし、クラスタリングのchullsを重ねることによってポイント構成をクラスタリングした結果。問題：最初の2つのプロットは問題なく動作します。代わりに、第三のプロットで、私はエラーを取得する：「データ」は、ベクトル型である必

3熱

1答えて

Angular2反応形式は複数の属性を選択しますか？

私のアプリケーションでは、反応するフォームで次のコードを使用します。私は[multiple]行のコメントを解除した場合、はオプションは、ステータスINVALIDに戻っdformControlフォームコントロールオブジェクトを設定しません...選択してください。 dformControl.multipleところでfalseを返します。コメントされた行を[multiple]="false"に変更して

0熱

1答えて

RxJavaは実際にスレッド化に関して内部的にどのように動作しますか？

私はRxJavaでリアクティブアプリケーションを作成する経験があります。しかし、私はそれ（そしてSpring Reactorのような他のライブラリ）が実際に内部で作業する方法を知っています。私はそのオンラインに関する面白い情報を見つけることができないようであり、典型的なシンプルなチュートリアルだけです。スレッディングなどはどうやって処理されますか？すべての「アクター」は同じスレッドで動作しますか？

0熱

1答えて

内部観測可能なエラーだけを再試行する方法は？

私は、次のサンプルを持っている： const result = http.get('http://google.com') .switchMap(() => 'http://example.com') // This retry should retry only example.com .retryWhen(error =>

0熱

1答えて

オブザーバーがBehaviourSubject /角2で完了するまで実行を待つ方法RxJS

私のコードには、アプリケーション全体で多くのオブザーバーを持つBehaviorSubjectがあります。 BehaviorSubjectで.next（）を実行すると、登録されたオブザーバーがすべて実行を完了したときを知る方法を知ることができます。

1熱

1答えて

このような何かすることはできなかったrxJavaの1.xではrxJava 2

に同じ加入者登録：） Observable.<Foo>create(subscriber -> { ... getNewObservable().subscribe(Subscribers.wrap(subscriber)); }) GetNewObservableを（私は同じアプローチを見つけることができないもObservable<Foo> を返しますrxJava 2.

0熱

1答えて

シャープな俳優に送るときにReactiveKafkaへの背圧

私はKafkaからの入力を受け取り、シャードされた俳優とのデータを処理してKafkaに出力するAkkaアプリケーションを作成しました。しかし、いくつかの場面でシャードの領域は、負荷を処理することができない、と私は得る：おそらくリモート接続をフラッディングを回避するためにフロー制御を実装する必要があります。このチェーン/フローにどのようにバックプレッシャーを実装できますか？カフカ消費者 -

1熱

1答えて

カスタムフィルタ演算子RxJava

私はRxJavaの栄光を受け入れ、それを自分のアプリケーションに統合しようとしています。私は累積コストが定義された予算を超えていないコミックを追加するために次のコードを書いています。これを実現するために、私は2つの実装を書いた。ためサブスクリプションを持つ複雑さと背圧がRxAndroid libに既に利用可能な演算子を使用し、主に推奨され Observable.create()を使用します。

3熱

1答えて

RACSignalからReactiveSwiftまたはRAC5への移行

私はSwiftの新機能です。そのため、Reactive Cocoa v5またはReactive Swiftの新機能です。は、以前私がRAC 2.xのでRACSignalを使用し、私はこのような何かが好き：私はそれが使い捨てにリクエストをキャンセルすることを愛し、そしてまた、私はdisposeを呼び出すことによって、それを手動で解除でき - (RACSignal *)signalForGET:(N