requery db＆rxjava observableResultは、後続の関数を複数回呼び出します。

Question

on android私はrequery dbを使用しており、DBの変更をサーバーにアップロードしようとしています。同じことを達成するために、私は次のロジック

Scheduler sub2 = Schedulers.newThread(); 
Scheduler ob2 = Schedulers.newThread(); 
data.select(Broadcaster.class) 
      .where(Broadcaster.IS_DIRTY.eq(true)) 
      .get() 
      .observableResult() 
      .subscribeOn(sub2) 
      .observeOn(ob2) 
      .flatMap(broadcasters->broadcasters.observable()) 
      .flatMap(broadcasters->Backend.getInstance() 
        .uploadBroadcaster(broadcasters) 
        .onExceptionResumeNext(Observable.empty())) 
      .flatMapSingle(broadcaster -> markUploaded(broadcaster)) 
      .doOnError(t->Log.e(TAG,"Error uploading ",t)) 
      .subscribe(); 

を実行している。しかし、すべてのためにしています変更uploadBroadcasterは、同じデータを複数回（4-10回）と呼ばれています。 私はここで間違っています。

Answer 1

間違いは鉱山でした。このコードブロックは複数回呼び出されました。サブスクリプションが複数回発生しました。