RxJavaで長時間実行するタスクを処理する

Question

RxJavaを使用するために、サーバにメッセージを送信するAsyncTaskを移行しようとしています。おおよそ、タスクは次のない：

1）送信されるメッセージ（データベースへの持続）
2を作成し）、ユーザ（状態「送信」）
3にメッセージを表示）メッセージを送信）サーバー（以下のコードスニペット）
4に送信されたとしてメッセージをマークしたか失敗した（データベースへの持続）
5）私は部分的にこのようになり、必要な受信チェーンを作成したUI

を更新します：

public Observable<Message> sendMessage(Message message) { 
    return mApiClient.sendMessage(message) 
     .doOnNext(sentMessage -> mDatabase.synchroniseMessage(sentMessage)) 
     .doOnError(e -> { 
      message.setState(FAILED); 
      mDatabase.synchroniseMessage(message)); 
     }) 
     .onErrorReturn(e -> Observable.just(message)); 

上記を購読すると、Disposableとなります。通常、私はそれをCompositeDisposableオブジェクトに追加し、そのオブジェクトに対応するclearを追加して、別のview（つまりfragment）に移動しました。ただし、この場合は、ローカルデータベースがタスク結果に応じて更新されるように、このタスクを実行しておく必要があります。

この状況を処理する最も適切な方法は何でしょうか？私は単にDisposableを私のCompositeDisposableオブジェクトに追加することはできません。そのため、登録解除されませんが、問題を引き起こす可能性があります。

P.S.ユーザーへの更新を表示するには、SQLiteテーブルのデータを観察します。これらのイベントは、synchroniseMessageメソッドによってトリガーされます。これは私が単純に退会する異なるサブスクリプションなので、問題の一部ではありません。

Answer 1

1人は、もはや彼が興味を持たなくなるとすぐにDisposableを処分します。

ユーザーが別の画面にナビゲートするかどうかにかかわらずストリームに興味がある場合は、そのストリームからの参加を拒否できません。つまり、CompositeDisposableに追加することはできません。

Subscriptionからの暗黙的な参照のために、Activityがガベージコレクションできない状況が発生するため、メモリリーク状況が発生します。

このようなユースケースがある場合は、アクティビティのライフサイクルに依存しないコンポーネント（たとえば、Service）に対してそのリクエストを実行する必要があると思います。