Castopod/AntennaPod
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Avoid error delivery to disposed Disposable

Browse Source
This commit is contained in:
Joe Stein 2019-05-21 18:03:42 -04:00
parent c98a7c0c38
commit 382860d65e
1 changed files with 8 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
app/src/main/java/de/danoeh/antennapod/fragment/ItunesSearchFragment.java
View File

@ -5,6 +5,7 @@ import android.os.Bundle;
import android.support.v4.app.Fragment; import android.support.v4.app.Fragment;
import android.support.v4.view.MenuItemCompat; import android.support.v4.view.MenuItemCompat;
import android.support.v7.widget.SearchView; import android.support.v7.widget.SearchView;
import android.support.annotation.NonNull;
import android.util.Log; import android.util.Log;
import android.view.LayoutInflater; import android.view.LayoutInflater;
import android.view.Menu; import android.view.Menu;
@ -106,7 +107,7 @@ public class ItunesSearchFragment extends Fragment {
} }
@Override @Override
public View onCreateView(LayoutInflater inflater, ViewGroup container, public View onCreateView(@NonNull LayoutInflater inflater, ViewGroup container,
Bundle savedInstanceState) { Bundle savedInstanceState) {
// Inflate the layout for this fragment // Inflate the layout for this fragment
View root = inflater.inflate(R.layout.fragment_itunes_search, container, false); View root = inflater.inflate(R.layout.fragment_itunes_search, container, false);
@ -146,8 +147,10 @@ public class ItunesSearchFragment extends Fragment {
emitter.onError(new IOException(prefix + response)); emitter.onError(new IOException(prefix + response));
} }
} catch (IOException | JSONException e) { } catch (IOException | JSONException e) {
if (!disposable.isDisposed()) {
emitter.onError(e); emitter.onError(e);
} }
}
}) })
.subscribeOn(Schedulers.io()) .subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread()) .observeOn(AndroidSchedulers.mainThread())
@ -249,8 +252,10 @@ public class ItunesSearchFragment extends Fragment {
List<Podcast> podcasts = parseFeed(feedString); List<Podcast> podcasts = parseFeed(feedString);
emitter.onSuccess(podcasts); emitter.onSuccess(podcasts);
} catch (IOException | JSONException e) { } catch (IOException | JSONException e) {
if (!disposable.isDisposed()) {
emitter.onError(e); emitter.onError(e);
} }
}
}) })
.subscribeOn(Schedulers.io()) .subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread()) .observeOn(AndroidSchedulers.mainThread())