diff --git a/base/src/main/kotlin/io/goooler/demoapp/base/util/BaseExtensions.kt b/base/src/main/kotlin/io/goooler/demoapp/base/util/BaseExtensions.kt
index 81a34dcdd..473d65eb8 100644
--- a/base/src/main/kotlin/io/goooler/demoapp/base/util/BaseExtensions.kt
+++ b/base/src/main/kotlin/io/goooler/demoapp/base/util/BaseExtensions.kt
@@ -32,7 +32,6 @@ import androidx.core.os.bundleOf
 import androidx.core.text.parseAsHtml
 import androidx.core.text.toSpannable
 import androidx.databinding.DataBindingUtil
-import androidx.databinding.ObservableField
 import androidx.databinding.ViewDataBinding
 import androidx.fragment.app.Fragment
 import androidx.fragment.app.FragmentActivity
@@ -91,10 +90,6 @@ typealias MutableStringLiveData = MutableLiveData<String?>
 
 typealias MutableListLiveData<T> = MutableLiveData<List<T>>
 
-typealias ObservableString = ObservableField<String?>
-
-typealias ObservableList<T> = ObservableField<List<T>>
-
 typealias ParamMap = HashMap<String, Any>
 
 // ---------------------Any-------------------------------//
@@ -107,7 +102,8 @@ inline val currentThreadName: String get() = Thread.currentThread().name
 
 inline val isMainThread: Boolean get() = Looper.getMainLooper() == Looper.myLooper()
 
-fun <T> unsafeLazy(initializer: () -> T): Lazy<T> = lazy(LazyThreadSafetyMode.NONE, initializer)
+fun <T : Any> unsafeLazy(initializer: () -> T): Lazy<T> =
+  lazy(LazyThreadSafetyMode.NONE, initializer)
 
 fun <T> MutableLiveData<T>.asLiveData(): LiveData<T> = this
 
diff --git a/common/src/main/kotlin/io/goooler/demoapp/common/util/CommonExtensions.kt b/common/src/main/kotlin/io/goooler/demoapp/common/util/CommonExtensions.kt
index 2961e6ec9..f99c561bd 100644
--- a/common/src/main/kotlin/io/goooler/demoapp/common/util/CommonExtensions.kt
+++ b/common/src/main/kotlin/io/goooler/demoapp/common/util/CommonExtensions.kt
@@ -183,19 +183,19 @@ fun Number.formatMoney(isYuan: Boolean = false, trans2W: Boolean = false, scale:
 
 // ---------------------Rx-------------------------------//
 
-fun <T> Single<T>.subscribeOnIoThread(): Single<T> = subscribeOn(Schedulers.io())
+fun <T : Any> Single<T>.subscribeOnIoThread(): Single<T> = subscribeOn(Schedulers.io())
 
-fun <T> Single<T>.observeOnMainThread(): Single<T> = observeOn(AndroidSchedulers.mainThread())
+fun <T : Any> Single<T>.observeOnMainThread(): Single<T> = observeOn(AndroidSchedulers.mainThread())
 
-fun <T> Single<T>.subscribeAndObserve(): Single<T> =
+fun <T : Any> Single<T>.subscribeAndObserve(): Single<T> =
   subscribeOnIoThread().observeOnMainThread()
 
-fun <T> Observable<T>.subscribeOnIoThread(): Observable<T> = subscribeOn(Schedulers.io())
+fun <T : Any> Observable<T>.subscribeOnIoThread(): Observable<T> = subscribeOn(Schedulers.io())
 
-fun <T> Observable<T>.observeOnMainThread(): Observable<T> =
+fun <T : Any> Observable<T>.observeOnMainThread(): Observable<T> =
   observeOn(AndroidSchedulers.mainThread())
 
-fun <T> Observable<T>.subscribeAndObserve(): Observable<T> =
+fun <T : Any> Observable<T>.subscribeAndObserve(): Observable<T> =
   subscribeOnIoThread().observeOnMainThread()
 
 // ---------------------Res-------------------------------//
diff --git a/test/src/main/kotlin/io/goooler/demoapp/test/network/exception/CustomObservableObserver.kt b/test/src/main/kotlin/io/goooler/demoapp/test/network/exception/CustomObservableObserver.kt
deleted file mode 100644
index 7de05ff24..000000000
--- a/test/src/main/kotlin/io/goooler/demoapp/test/network/exception/CustomObservableObserver.kt
+++ /dev/null
@@ -1,22 +0,0 @@
-package io.goooler.demoapp.test.network.exception
-
-import io.goooler.demoapp.common.network.BaseResponse
-import io.reactivex.rxjava3.observers.DisposableObserver
-
-abstract class CustomObservableObserver<T : BaseResponse> :
-  DisposableObserver<T>(),
-  CustomObserver<T> {
-
-  override fun onNext(t: T) {
-    if (t.code == 200)
-      onCustomSuccess(t)
-    else
-      onCustomError((t.message ?: t.code.toString()).toResponseException())
-  }
-
-  override fun onError(e: Throwable?) {
-    onCustomError(e.toResponseException())
-  }
-
-  override fun onComplete() {}
-}
diff --git a/test/src/main/kotlin/io/goooler/demoapp/test/network/exception/CustomSingleObserver.kt b/test/src/main/kotlin/io/goooler/demoapp/test/network/exception/CustomObservers.kt
similarity index 55%
rename from test/src/main/kotlin/io/goooler/demoapp/test/network/exception/CustomSingleObserver.kt
rename to test/src/main/kotlin/io/goooler/demoapp/test/network/exception/CustomObservers.kt
index eaade112c..ab14d0d85 100644
--- a/test/src/main/kotlin/io/goooler/demoapp/test/network/exception/CustomSingleObserver.kt
+++ b/test/src/main/kotlin/io/goooler/demoapp/test/network/exception/CustomObservers.kt
@@ -1,13 +1,21 @@
 package io.goooler.demoapp.test.network.exception
 
 import io.goooler.demoapp.common.network.BaseResponse
+import io.reactivex.rxjava3.observers.DisposableObserver
 import io.reactivex.rxjava3.observers.DisposableSingleObserver
 
-abstract class CustomSingleObserver<T : BaseResponse> :
-  DisposableSingleObserver<T>(),
+sealed interface CustomObserver<T : Any> {
+
+  fun onCustomSuccess(t: T)
+
+  fun onCustomError(e: ResponseException)
+}
+
+abstract class CustomObservableObserver<T : BaseResponse> :
+  DisposableObserver<T>(),
   CustomObserver<T> {
 
-  override fun onSuccess(t: T) {
+  override fun onNext(t: T) {
     if (t.code == 200)
       onCustomSuccess(t)
     else
@@ -17,11 +25,22 @@ abstract class CustomSingleObserver<T : BaseResponse> :
   override fun onError(e: Throwable) {
     onCustomError(e.toResponseException())
   }
+
+  override fun onComplete() {}
 }
 
-sealed interface CustomObserver<T> {
+abstract class CustomSingleObserver<T : BaseResponse> :
+  DisposableSingleObserver<T>(),
+  CustomObserver<T> {
 
-  fun onCustomSuccess(t: T)
+  override fun onSuccess(t: T) {
+    if (t.code == 200)
+      onCustomSuccess(t)
+    else
+      onCustomError((t.message ?: t.code.toString()).toResponseException())
+  }
 
-  fun onCustomError(e: ResponseException)
+  override fun onError(e: Throwable) {
+    onCustomError(e.toResponseException())
+  }
 }