Commit f7a650b9 authored by topjohnwu's avatar topjohnwu

Clear up RxJava from ViewModels

parent a97d278b
...@@ -18,8 +18,6 @@ import com.topjohnwu.magisk.extensions.value ...@@ -18,8 +18,6 @@ import com.topjohnwu.magisk.extensions.value
import com.topjohnwu.magisk.model.events.* import com.topjohnwu.magisk.model.events.*
import com.topjohnwu.magisk.model.navigation.NavigationWrapper import com.topjohnwu.magisk.model.navigation.NavigationWrapper
import com.topjohnwu.magisk.model.observer.Observer import com.topjohnwu.magisk.model.observer.Observer
import io.reactivex.disposables.CompositeDisposable
import io.reactivex.disposables.Disposable
import kotlinx.coroutines.Job import kotlinx.coroutines.Job
import org.koin.core.KoinComponent import org.koin.core.KoinComponent
...@@ -45,9 +43,7 @@ abstract class BaseViewModel( ...@@ -45,9 +43,7 @@ abstract class BaseViewModel(
notifyStateChanged() notifyStateChanged()
} }
private val disposables = CompositeDisposable()
private val _viewEvents = MutableLiveData<ViewEvent>() private val _viewEvents = MutableLiveData<ViewEvent>()
private var runningTask: Disposable? = null
private var runningJob: Job? = null private var runningJob: Job? = null
private val refreshCallback = object : Observable.OnPropertyChangedCallback() { private val refreshCallback = object : Observable.OnPropertyChangedCallback() {
override fun onPropertyChanged(sender: Observable?, propertyId: Int) { override fun onPropertyChanged(sender: Observable?, propertyId: Int) {
...@@ -68,8 +64,6 @@ abstract class BaseViewModel( ...@@ -68,8 +64,6 @@ abstract class BaseViewModel(
runningJob = refresh() runningJob = refresh()
} }
protected open fun rxRefresh(): Disposable? = null
protected open fun refresh(): Job? = null protected open fun refresh(): Job? = null
open fun notifyStateChanged() { open fun notifyStateChanged() {
...@@ -81,7 +75,6 @@ abstract class BaseViewModel( ...@@ -81,7 +75,6 @@ abstract class BaseViewModel(
@CallSuper @CallSuper
override fun onCleared() { override fun onCleared() {
isConnected.removeOnPropertyChangedCallback(refreshCallback) isConnected.removeOnPropertyChangedCallback(refreshCallback)
disposables.clear()
super.onCleared() super.onCleared()
} }
...@@ -111,10 +104,6 @@ abstract class BaseViewModel( ...@@ -111,10 +104,6 @@ abstract class BaseViewModel(
_viewEvents.postValue(NavigationWrapper(this)) _viewEvents.postValue(NavigationWrapper(this))
} }
fun Disposable.add() {
disposables.add(this)
}
// The following is copied from androidx.databinding.BaseObservable // The following is copied from androidx.databinding.BaseObservable
@Transient @Transient
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment