diff --git a/data/src/main/java/com/moez/QKSMS/listener/ContactAddedListenerImpl.kt b/data/src/main/java/com/moez/QKSMS/listener/ContactAddedListenerImpl.kt
index 90b62fbd..9670b97c 100644
--- a/data/src/main/java/com/moez/QKSMS/listener/ContactAddedListenerImpl.kt
+++ b/data/src/main/java/com/moez/QKSMS/listener/ContactAddedListenerImpl.kt
@@ -25,7 +25,6 @@ import android.os.Handler
 import android.provider.ContactsContract
 import com.moez.QKSMS.repository.SyncRepository
 import io.reactivex.Observable
-import io.reactivex.Single
 import io.reactivex.subjects.PublishSubject
 import javax.inject.Inject
 
@@ -43,11 +42,9 @@ class ContactAddedListenerImpl @Inject constructor(
         private val URI = ContactsContract.CommonDataKinds.Phone.CONTENT_URI
     }
 
-    override fun listen(address: String): Single<*> {
-        val observable = ContactContentObserver(context).observable
+    override fun listen(address: String): Observable<*> {
+        return ContactContentObserver(context).observable
                 .filter { syncRepo.syncContact(address) }
-
-        return Single.fromObservable(observable)
     }
 
     private class ContactContentObserver(context: Context) : ContentObserver(Handler()) {
diff --git a/domain/src/main/java/com/moez/QKSMS/listener/ContactAddedListener.kt b/domain/src/main/java/com/moez/QKSMS/listener/ContactAddedListener.kt
index 072d23bb..1d2d1c50 100644
--- a/domain/src/main/java/com/moez/QKSMS/listener/ContactAddedListener.kt
+++ b/domain/src/main/java/com/moez/QKSMS/listener/ContactAddedListener.kt
@@ -18,10 +18,10 @@
  */
 package com.moez.QKSMS.listener
 
-import io.reactivex.Single
+import io.reactivex.Observable
 
 interface ContactAddedListener {
 
-    fun listen(address: String): Single<*>
+    fun listen(address: String): Observable<*>
 
 }
\ No newline at end of file