From f12a899082d319b3af728f1f34fc7570447f0bb4 Mon Sep 17 00:00:00 2001 From: Moez Bhatti Date: Wed, 19 Sep 2018 19:44:19 -0400 Subject: [PATCH] Fix crash when multiple changes made to contact --- .../com/moez/QKSMS/listener/ContactAddedListenerImpl.kt | 7 ++----- .../java/com/moez/QKSMS/listener/ContactAddedListener.kt | 4 ++-- 2 files changed, 4 insertions(+), 7 deletions(-) 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