Disposable now is cleaned properly
This commit is contained in:
parent
0b58b6d52d
commit
6bd694dba3
1 changed files with 2 additions and 1 deletions
|
|
@ -405,6 +405,7 @@ public class SubscriptionFragment extends BaseStateFragment<List<SubscriptionEnt
|
||||||
|
|
||||||
@SuppressLint("CheckResult")
|
@SuppressLint("CheckResult")
|
||||||
private void deleteChannel (ChannelInfoItem selectedItem) {
|
private void deleteChannel (ChannelInfoItem selectedItem) {
|
||||||
|
disposables.add(
|
||||||
ExtractorHelper.getChannelInfo(selectedItem.getServiceId(), selectedItem.getUrl(), true)
|
ExtractorHelper.getChannelInfo(selectedItem.getServiceId(), selectedItem.getUrl(), true)
|
||||||
.subscribeOn(Schedulers.io())
|
.subscribeOn(Schedulers.io())
|
||||||
.observeOn(Schedulers.newThread())
|
.observeOn(Schedulers.newThread())
|
||||||
|
|
@ -413,7 +414,7 @@ public class SubscriptionFragment extends BaseStateFragment<List<SubscriptionEnt
|
||||||
.getSubscription(result.getServiceId(), result.getUrl())
|
.getSubscription(result.getServiceId(), result.getUrl())
|
||||||
.blockingFirst();
|
.blockingFirst();
|
||||||
subscriptionService.subscriptionTable().delete(toDelete);
|
subscriptionService.subscriptionTable().delete(toDelete);
|
||||||
});
|
}));
|
||||||
}
|
}
|
||||||
|
|
||||||
private void resetFragment() {
|
private void resetFragment() {
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue