From f436cf2e9fb918286e72be9109bd34804970f256 Mon Sep 17 00:00:00 2001 From: InsanusMokrassar Date: Fri, 7 Sep 2018 22:58:38 +0800 Subject: [PATCH] fix notification about psychomatrix changes --- .../ModifyPsychomatrixUseCaseInteractor.kt | 15 +++++++++++++-- 1 file changed, 13 insertions(+), 2 deletions(-) diff --git a/src/main/kotlin/com/github/insanusmokrassar/PsychomatrixBase/domain/interactors/ModifyPsychomatrixUseCaseInteractor.kt b/src/main/kotlin/com/github/insanusmokrassar/PsychomatrixBase/domain/interactors/ModifyPsychomatrixUseCaseInteractor.kt index d438c5d..280ab5c 100644 --- a/src/main/kotlin/com/github/insanusmokrassar/PsychomatrixBase/domain/interactors/ModifyPsychomatrixUseCaseInteractor.kt +++ b/src/main/kotlin/com/github/insanusmokrassar/PsychomatrixBase/domain/interactors/ModifyPsychomatrixUseCaseInteractor.kt @@ -8,6 +8,7 @@ import com.github.insanusmokrassar.PsychomatrixBase.domain.entities.operations.O import com.github.insanusmokrassar.PsychomatrixBase.utils.extensions.SUBSCRIPTIONS_MEDIUM import kotlinx.coroutines.experimental.channels.BroadcastChannel import kotlinx.coroutines.experimental.channels.ReceiveChannel +import kotlinx.coroutines.experimental.launch class ModifyPsychomatrixUseCaseInteractor : ModifyPsychomatrixUseCase { private val currentPsychomatrixes: MutableList = ArrayList() @@ -19,11 +20,21 @@ class ModifyPsychomatrixUseCaseInteractor : ModifyPsychomatrixUseCase { } override fun makeConvert(psychomatrix: MutablePsychomatrix, operation: Operation): Boolean { - return asMutablePsychomatrix(psychomatrix).applyConvert(operation) + return asMutablePsychomatrix(psychomatrix).applyConvert(operation).also { + if (it) { + launch { + psychomatrixChangedBroadcastChannel.send(psychomatrix to (operation to true)) + } + } + } } override fun makeInvert(psychomatrix: MutablePsychomatrix, operation: Operation): Boolean { - return asMutablePsychomatrix(psychomatrix).applyInvert(operation) + return asMutablePsychomatrix(psychomatrix).applyInvert(operation).also { + launch { + psychomatrixChangedBroadcastChannel.send(psychomatrix to (operation to false)) + } + } } override fun getConverts(psychomatrix: Psychomatrix): List {