Fixed subscription

This commit is contained in:
Nite 2021-11-15 18:20:26 +01:00
parent bb36116d70
commit e019ec788d
No known key found for this signature in database
GPG Key ID: 1D1AD59B1C6386C1
1 changed files with 4 additions and 1 deletions

View File

@ -39,6 +39,7 @@ import androidx.lifecycle.lifecycleScope
import androidx.navigation.Navigation import androidx.navigation.Navigation
import com.mobeta.android.dslv.DragSortListView import com.mobeta.android.dslv.DragSortListView
import com.mobeta.android.dslv.DragSortListView.DragSortListener import com.mobeta.android.dslv.DragSortListView.DragSortListener
import io.reactivex.rxjava3.disposables.Disposable
import java.text.DateFormat import java.text.DateFormat
import java.text.SimpleDateFormat import java.text.SimpleDateFormat
import java.util.ArrayList import java.util.ArrayList
@ -112,6 +113,7 @@ class PlayerFragment : Fragment(), GestureDetector.OnGestureListener, KoinCompon
private var currentPlaying: DownloadFile? = null private var currentPlaying: DownloadFile? = null
private var currentSong: MusicDirectory.Entry? = null private var currentSong: MusicDirectory.Entry? = null
private var onProgressChangedTask: SilentBackgroundTask<Void?>? = null private var onProgressChangedTask: SilentBackgroundTask<Void?>? = null
private var rxBusSubscription: Disposable? = null
// Views and UI Elements // Views and UI Elements
private lateinit var visualizerViewLayout: LinearLayout private lateinit var visualizerViewLayout: LinearLayout
@ -422,7 +424,7 @@ class PlayerFragment : Fragment(), GestureDetector.OnGestureListener, KoinCompon
) )
// Observe playlist changes and update the UI // Observe playlist changes and update the UI
RxBus.playlistObservable.subscribe { rxBusSubscription = RxBus.playlistObservable.subscribe {
onPlaylistChanged() onPlaylistChanged()
} }
@ -488,6 +490,7 @@ class PlayerFragment : Fragment(), GestureDetector.OnGestureListener, KoinCompon
} }
override fun onDestroyView() { override fun onDestroyView() {
rxBusSubscription?.dispose()
cancellationToken.cancel() cancellationToken.cancel()
super.onDestroyView() super.onDestroyView()
} }