refactor code

app/src/main/java/code/name/monkey/retromusic/misc/DisposableManager.kt

@@ -0,0 +1,24 @@
+package code.name.monkey.retromusic.misc
+
+import io.reactivex.disposables.CompositeDisposable
+import io.reactivex.disposables.Disposable
+
+object DisposableManager {
+
+    private var compositeDisposable: CompositeDisposable? = null
+
+    fun add(disposable: Disposable) {
+        getCompositeDisposable().add(disposable)
+    }
+
+    fun dispose() {
+        getCompositeDisposable().dispose()
+    }
+
+    private fun getCompositeDisposable(): CompositeDisposable {
+        if (compositeDisposable == null || compositeDisposable!!.isDisposed) {
+            compositeDisposable = CompositeDisposable()
+        }
+        return compositeDisposable!!
+    }
+}

app/src/main/java/code/name/monkey/retromusic/misc/DisposingObserver.kt

@@ -0,0 +1,18 @@
+package code.name.monkey.retromusic.misc
+
+import androidx.annotation.CallSuper
+import io.reactivex.Observer
+import io.reactivex.disposables.Disposable
+
+class DisposingObserver<T> : Observer<T> {
+    @CallSuper
+    override fun onSubscribe(d: Disposable) {
+        DisposableManager.add(d)
+    }
+
+    override fun onNext(next: T) {}
+
+    override fun onError(e: Throwable) {}
+
+    override fun onComplete() {}
+}