fix: Resolve thread issue in BlockedNumbers

import com.moez.QKSMS.repository.ConversationRepository

import com.moez.QKSMS.repository.ConversationRepository

import com.uber.autodispose.android.lifecycle.scope

import com.uber.autodispose.android.lifecycle.scope

import com.uber.autodispose.autoDisposable

import com.uber.autodispose.autoDisposable

import io.reactivex.Completable

import io.reactivex.schedulers.Schedulers

import io.reactivex.schedulers.Schedulers

import timber.log.Timber

import javax.inject.Inject

import javax.inject.Inject

class BlockedNumbersPresenter @Inject constructor(

class BlockedNumbersPresenter @Inject constructor(

        super.bindIntents(view)

        super.bindIntents(view)

        view.unblockAddress()

        view.unblockAddress()

                .doOnNext { id ->

            .flatMapCompletable { id ->

                Completable.fromAction {

                    blockingRepo.getBlockedNumber(id)?.address

                    blockingRepo.getBlockedNumber(id)?.address

                        ?.let(conversationRepo::getThreadId)

                        ?.let(conversationRepo::getThreadId)

                        ?.let { threadId -> markUnblocked.execute(listOf(threadId)) }

                        ?.let { threadId -> markUnblocked.execute(listOf(threadId)) }

                    blockingRepo.unblockNumber(id)

                }

                }

                .doOnNext(blockingRepo::unblockNumber)

                    .subscribeOn(Schedulers.io())

                    .subscribeOn(Schedulers.io())

            }

            .autoDisposable(view.scope())

            .autoDisposable(view.scope())

                .subscribe()

            .subscribe({ }, Timber::w)

        view.addAddress()

        view.addAddress()

            .autoDisposable(view.scope())

            .autoDisposable(view.scope())

            .subscribe { view.showAddDialog() }

            .subscribe { view.showAddDialog() }

        view.saveAddress()

        view.saveAddress()

            .flatMapCompletable { address ->

                Completable.fromAction { blockingRepo.blockNumber(address) }

                    .subscribeOn(Schedulers.io())

                    .subscribeOn(Schedulers.io())

            }

            .autoDisposable(view.scope())

            .autoDisposable(view.scope())

                .subscribe { address -> blockingRepo.blockNumber(address) }

            .subscribe({ }, Timber::w)

    }

    }

}

}