Как отменить async Наблюдаемый поток при отмене подписки

Question

Как отменить асинхронный наблюдаемый поток при отписании? У меня следующая ситуация:

Observable.fromCallable(() -> api.UploadData(data)) 
.subscribeOn(Schedulers.from(threadExecutor)) 
.observeOn(AndroidSchedulers.mainThread()) 
.subscribe(subscriber); 

После отписки на операцию уничтожения данных еще загрузки на другой поток, я хочу, чтобы отменить операцию загрузки. Как я могу это сделать ?

Answer 1

Вы можете попробовать doOnUnsubscribe и выполнить свое требование.

Observable.fromCallable(() -> api.UploadData(data)) 
    .subscribeOn(Schedulers.from(threadExecutor)) 
    .observeOn(AndroidSchedulers.mainThread()) 
    .doOnUnsubscribe(() -> api.StopUpload()) 
    .subscribe(subscriber);