reactivex

0熱

1答えて

angular2＆typescript＆reactX：httpをキャストする方法

このURLに残りのAPIがあるとします。/api/stuffs/ここでStuffのリストを取得できます。すべてがextractStuffs機能でstuffs配列はStuffの配列が、そして配列でないという事実を除いて、このコードで正常に動作します getStuffs(): Observable<Stuff[]> { return this.http.get(this.url)

0熱

2答えて

リアクティブAndroidでリフレッシュするときにサブスクリプションを追加する

サーバーからデータを取得してリストビューに表示するコードを書きました。また、私はリフレッシュ機能にプルを追加します。リフレッシュするときに追加のサブスクリプションを追加するかどうかは、ベストプラクティスなので、新しいサブスクリプションを追加する前に登録を解除する必要がありますか？ CompositeSubscription mSubscription = new CompositeSubscr

0熱

1答えて

複数の観測可能な要素が返されるのを待つ

シナリオ：複数の異なるバックエンドシステムをクエリするために使用するcustomerID文字列があります。カレンダー、ヘルプデスク、ERP、CRMなどです。単一のレポートをコンパイルします。は、だから私は（psydocode）おおよそ持っている： Result myResult = new Result(); Observable<Cal> cal = Calbackend.get(custo

6熱

1答えて

RxSwift - .subscribe vs .subscribeNext違いは何ですか？

これらの2つの演算子の違いは何ですか？ http://reactivex.ioには.subscribeNextはまったく言及されていません。

0熱

2答えて

RxJS/ReactiveX適切なモジュールの通信

私はリアクティブプログラミングにはかなり新しいですが、すでに愛しています。しかし、私の脳をそれに切り替えるのはまだ難しいです。私は、「被験者の使用を避ける」、「不純な機能を避ける」、そしてもちろん「必須コードを避ける」などの推奨事項に従っています。私が達成するのが難しいのは、1つのモジュールが "アクション" /観測可能と登録し、それに反応することができる単純なクロスモジュール通信です。単純なメ

1熱

1答えて

従属するオブザーバブルを連結する

第2のものが最初のものから返された値を必要とする場合、依存するAPIコールを作成する必要があります。（ID付き）Reportモデルを更新成功し、コールが戻った後、その後私はreport.IDが必要な場合、レポートのステップを作成するために、APIを呼び出す必要がどこ心に来る最初の事はflatMap ApiManager.shared .createReport(report: repo

2熱

1答えて

なぜ完全な連結を実行した後に呼び出されていませんか？

私は、デバイスを複数回照会する必要があります。すべてのクエリは非同期である必要があり、デバイスは一度に同時クエリをサポートしません。それが照会されるとまた、それは直後に再度照会することができません。正常に動作するには、少なくとも1秒の休止が必要です。 saveClock()とsaveConfig()によって実行される2つのクエリは、Promiseを返し、両方とも期待どおりに未定義を返して解決しま

1熱

1答えて

RxJava：BehaviorSubjectがソースからの後続の排出を受信しないObservable

BehaviorSubject（RxRelay.BehaviorRelay経由）を使用して、最新の排出を連続したObservableから保存しようとしています。「連続」とは、元のデータセットが変更されるたびにデータを放出するようにソースObservableが設計されていることを意味します。 BehaviorSubjectは、ソースObservableにサブスクライブされています。 Behavio

1熱

1答えて

RxPy - ライブTwitterストリームを受信可能なRxに変換しますか？

これに続いて、great tutorialはtweepyを使ってPythonでライブのTwitterストリームを活用しています。これにより、RxJava、RxPy、RxScala、またはReactiveXというライブタイムでツイートが印刷されます。 from tweepy.streaming import StreamListener from tweepy import OAuthHandle

3熱

1答えて

フライウェイトからの自己削除可能なリソース

私は、反応ストリームで作業しながら、私は閉じる必要があるさまざまなリソースを持つアプリケーションで作業しています。私は、オブジェクトへの参照を保持するフライウェイトパターンに基づいたファクトリを持っており、AutoCloseableインターフェイスを実装しています。問題は私がclose（）を使用しているのですが、のAutocloseableクラスです。私の質問です。工場内の閉じたリソースへの参