mirrors/NewPipe
1
0
Fork 0
mirror of https://github.com/TeamNewPipe/NewPipe synced 2024-11-17 23:34:54 +00:00
Code Issues Releases Wiki Activity

Disposable now is cleaned properly

Browse Source
This commit is contained in:
Somethingweirdhere 2018-06-30 02:20:01 +02:00
parent b9ea7ce066
commit 181a14ce59
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
app/src/main/java/org/schabi/newpipe/local/subscription/SubscriptionFragment.java
View File

@ -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() {