system.reactive

0熱

1答えて

私はRxJavaでオブザーバを使用している間に、実際に内部で何が起こっているのかを知りたいし、サブスクライバはどのようにオブザーバからすべてのデータストリームを取得しますか？ありがとうございます。

1熱

2答えて

更新イベントが毎秒150〜200回更新されます。私はこれをキーごとに1秒間にまとめたいと思っています。私はこの更新ごとに1秒を処理したいA1、B1、C1、A2、A3、B2 ：例：1秒でIの順に3つのキーA、B、Cの更新を受け取ります&プロセスのみA3、B2 &上記の例のC1。リアクティブエクステンションを使用してこれを行うにはどうすればよいですか？は、これまで私が試した： Observabl

1熱

2答えて

観測可能なサブスクリプションは正常に終了していますか？

リアクティブエクステンション（Rx）を使用してデータのストリームを処理しようとしています。ただし、各要素の処理には時間がかかることがあります。処理を中断するには、サブスクリプションを効果的に停止するCancellationTokenを使用しています。キャンセルが要求された場合、どのように正常に現在の作業を終了し、データを失うことなく正常に終了しますか？例： var cts = new Canc

-1熱

3答えて

代替最後に

私の理解ではshould be avoided、async voidこととActionで使用した場合async() =>がちょうどasync void変装であるということであるRxの中（）=>非同期を使用します。最後にパラメータとしてActionを受け入れるため、はしたがって、async() =>と非同期the Rx.NET Finally operatorを使用することは避けるべきである：これ

0熱

1答えて

私のサブジェクトに "ホットスワップ"オブザーバブル

私は一度限りの "遠く離れた"タイプのサブスクリプションで次のサブジェクトを持っています。 var subject = new Subject<int>(); subject.Subscribe(Console.WriteLine,() => Con.WriteLine("OnComplete")); は今、上記のコードは、私は1が表示されないので var sub = Observable.

-1熱

1答えて

オブジェクトの完全なリストを別のオブジェクトに入れる方法Rxjava

サービスでは、クライアントは1つ以上の関係を持っています。クライアントを取得したときにrxjavaを使用して、このクライアントオブジェクトからリレーションシップのリストを取得したいとします。以下のような何か： dataManager.getClient(clientId) .zipWith(???) .observeOn(AndroidSchedulers.

1熱

2答えて

リセットと私はこれがあると、反応性の拡張

、観察可能な加入者を処分：私はそれをリセットしたい AddDicomFileで観測可能 2-処分または終了したいCheckUploadSetListで public class UploadDicomSet { public UploadDicomSet() { var cachCleanTimer = Observable.Interval(TimeSpan.

1熱

1答えて

PlayストアからのみAndroid JAVA RX例外

こんにちは、私のGoogle PlayコンソールでRXからこの例外があります。私は自分のプロジェクトでこれを見たことがありませんでしたが、google playと言うと約200回発生しました。 1つはそれについてのアイデアを持っていますか？ java.lang.IllegalStateException： at rx.android.schedulers.LooperScheduler$Sched

2熱

1答えて

Rx.NET GroupByUntilグループの終了、スレッドの完了を待ちます

私は無限のオブジェクトストリームを持っています。そして、私の要件は、同じキーを持つ観測可能なストリームのすべてのアイテムを同期して処理し、異なるキーを持つ他のすべてのアイテムを並行して処理する必要があることです。 var results = observableStream .GroupByUntil(item => item.Id, group => group.Throt

0熱

1答えて

RxJava2は、completeまたはerrorを呼び出すとobservableを自動的に破棄しますか？

RxJavaの処分に関する質問があります。私はGithubのRxSwift文書の下でこれを見つけました。シーケンスは、シーケンスの要素を計算し、すべての内部リソースが解放されますcompletedまたはerrorイベントを送信します。シーケンス要素の生成をキャンセルしてすぐにリソースを解放するには、返されたサブスクリプションでdisposeを呼び出します。私が正しく理解していれば、彼らはon