Updated on 2026-08-14

app/src/main/java/com/tangem/tap/features/send/ui/SendFragment.kt

@@ -13,8 +13,8 @@ import androidx.core.view.postDelayed
 import androidx.core.widget.addTextChangedListener
 import androidx.fragment.app.viewModels
 import androidx.lifecycle.Lifecycle
-import androidx.lifecycle.flowWithLifecycle
 import androidx.lifecycle.lifecycleScope
+import androidx.lifecycle.repeatOnLifecycle
 import androidx.recyclerview.widget.LinearLayoutManager
 import androidx.recyclerview.widget.RecyclerView
 import arrow.core.getOrElse
@@ -54,14 +54,13 @@ import com.tangem.tap.features.send.redux.states.FeeType
 import com.tangem.tap.features.send.redux.states.MainCurrencyType
 import com.tangem.tap.features.send.ui.adapters.WarningMessagesAdapter
 import com.tangem.tap.features.send.ui.stateSubscribers.SendStateSubscriber
-import com.tangem.tap.mainScope
 import com.tangem.tap.store
 import com.tangem.wallet.R
 import com.tangem.wallet.databinding.FragmentSendBinding
 import dagger.hilt.android.AndroidEntryPoint
+import kotlinx.coroutines.CoroutineScope
 import kotlinx.coroutines.FlowPreview
 import kotlinx.coroutines.channels.awaitClose
-import kotlinx.coroutines.delay
 import kotlinx.coroutines.flow.*
 import kotlinx.coroutines.launch
 import timber.log.Timber
@@ -73,6 +72,7 @@ private const val EDIT_TEXT_INPUT_DEBOUNCE = 400L
 /**
 [REDACTED_AUTHOR]
  */
+@Suppress("LargeClass")
 @OptIn(FlowPreview::class)
 @AndroidEntryPoint
 class SendFragment : BaseStoreFragment(R.layout.fragment_send) {
@@ -103,18 +103,25 @@ class SendFragment : BaseStoreFragment(R.layout.fragment_send) {
         lifecycle.addObserver(viewModel)
         sendSubscriber.initViewModel(viewModel)
         Analytics.send(Token.Send.ScreenOpened())
-        listenToQrCode()
     }
 
     override fun onViewCreated(view: View, savedInstanceState: Bundle?) {
         super.onViewCreated(view, savedInstanceState)
+        viewLifecycleOwner.lifecycleScope.launch {
+            repeatOnLifecycle(Lifecycle.State.STARTED) {
+                subscribeToQrCodeScanner()
+                subscribeToTransactionExtrasFields()
+                subscribeToAddressField()
+                subscribeToAmountField()
+            }
+        }
+
         addBackPressHandler(this)
 
         etAmountToSend = view.findViewById(R.id.etAmountToSend)
 
         initSendButtonStates()
         setupAddressLayout()
-        setupTransactionExtrasLayout()
         setupAmountLayout()
         setupFeeLayout()
         setupWarningMessages()
@@ -149,14 +156,6 @@ class SendFragment : BaseStoreFragment(R.layout.fragment_send) {
             setOnFocusChangeListener { _, hasFocus ->
                 store.dispatch(TruncateOrRestore(!hasFocus))
             }
-
-            inputtedTextAsFlow()
-                .debounce(EDIT_TEXT_INPUT_DEBOUNCE)
-                .filter { store.state.sendState.addressState.viewFieldValue.value != it }
-                .onEach {
-                    store.dispatch(AddressActionUi.HandleUserInput(it))
-                }
-                .launchIn(mainScope)
         }
 
         imvPaste.setOnClickListener {
@@ -183,31 +182,41 @@ class SendFragment : BaseStoreFragment(R.layout.fragment_send) {
         }
     }
 
-    private fun listenToQrCode() {
-        lifecycleScope.launch {
-            listenToQrScanningUseCase(SourceType.SEND)
-                .getOrElse { emptyFlow() }
-                .flowWithLifecycle(this@SendFragment.lifecycle, minActiveState = Lifecycle.State.CREATED)
-                .collect { rawQr ->
-                    delay(200)
-
-                    // Delayed launch is needed in order for the UI to be drawn and to process the sent events.
-                    // If do not use the delay, then etAmount error field is not displayed when
-                    // inserting an incorrect amount by shareUri
-                    cryptoCurrency?.let { cryptoCurrency ->
-                        parseQrCodeUseCase(rawQr, cryptoCurrency = cryptoCurrency).fold(
-                            ifLeft = {
-                                onCodeScanned(QrResult(address = rawQr))
-                                Timber.w(it)
-                            },
-                            ifRight = { onCodeScanned(it) },
-                        )
-                    } ?: onCodeScanned(QrResult(address = rawQr))
-                }
-        }
+    private fun CoroutineScope.subscribeToAddressField() = with(binding.lSendAddress) {
+        etAddress.inputtedTextAsFlow()
+            .debounce(EDIT_TEXT_INPUT_DEBOUNCE)
+            .filter { store.state.sendState.addressState.viewFieldValue.value != it }
+            .onEach {
+                store.dispatch(AddressActionUi.HandleUserInput(it))
+            }
+            .launchIn(this@subscribeToAddressField)
     }
 
-    private fun setupTransactionExtrasLayout() = with(binding.lSendAddress) {
+    private fun CoroutineScope.subscribeToAmountField() {
+        etAmountToSend.inputtedTextAsFlow()
+            .debounce(EDIT_TEXT_INPUT_DEBOUNCE)
+            .filter { store.state.sendState.amountState.viewAmountValue.value != it && it.isNotEmpty() }
+            .onEach { store.dispatch(AmountActionUi.HandleUserInput(it)) }
+            .launchIn(this)
+    }
+
+    private fun CoroutineScope.subscribeToQrCodeScanner() {
+        listenToQrScanningUseCase(SourceType.SEND)
+            .getOrElse { emptyFlow() }
+            .onEach { rawQr ->
+                cryptoCurrency?.let { cryptoCurrency ->
+                    parseQrCodeUseCase(rawQr, cryptoCurrency = cryptoCurrency).fold(
+                        ifLeft = {
+                            onCodeScanned(QrResult(address = rawQr))
+                            Timber.w(it)
+                        },
+                        ifRight = { onCodeScanned(it) },
+                    )
+                } ?: onCodeScanned(QrResult(address = rawQr))
+            }.launchIn(this)
+    }
+
+    private fun CoroutineScope.subscribeToTransactionExtrasFields() = with(binding.lSendAddress) {
         // TODO: [REDACTED_TASK_KEY]
         etXlmMemo.inputtedTextAsFlow()
             .debounce(EDIT_TEXT_INPUT_DEBOUNCE)
@@ -216,7 +225,7 @@ class SendFragment : BaseStoreFragment(R.layout.fragment_send) {
                 info.xlmMemo?.viewFieldValue?.value != it
             }
             .onEach { store.dispatch(TransactionExtrasAction.XlmMemo.HandleUserInput(it)) }
-            .launchIn(mainScope)
+            .launchIn(this@subscribeToTransactionExtrasFields)
 
         etDestinationTag.inputtedTextAsFlow()
             .debounce(EDIT_TEXT_INPUT_DEBOUNCE)
@@ -225,7 +234,7 @@ class SendFragment : BaseStoreFragment(R.layout.fragment_send) {
                 info.xrpDestinationTag?.viewFieldValue?.value != it
             }
             .onEach { store.dispatch(TransactionExtrasAction.XrpDestinationTag.HandleUserInput(it)) }
-            .launchIn(mainScope)
+            .launchIn(this@subscribeToTransactionExtrasFields)
 
         etBinanceMemo.inputtedTextAsFlow()
             .debounce(EDIT_TEXT_INPUT_DEBOUNCE)
@@ -234,7 +243,7 @@ class SendFragment : BaseStoreFragment(R.layout.fragment_send) {
                 info.binanceMemo?.viewFieldValue?.value != it
             }
             .onEach { store.dispatch(TransactionExtrasAction.BinanceMemo.HandleUserInput(it)) }
-            .launchIn(mainScope)
+            .launchIn(this@subscribeToTransactionExtrasFields)
 
         etTonMemo.inputtedTextAsFlow()
             .debounce(EDIT_TEXT_INPUT_DEBOUNCE)
@@ -243,7 +252,7 @@ class SendFragment : BaseStoreFragment(R.layout.fragment_send) {
                 info.tonMemoState?.viewFieldValue?.value != it
             }
             .onEach { store.dispatch(TransactionExtrasAction.TonMemo.HandleUserInput(it)) }
-            .launchIn(mainScope)
+            .launchIn(this@subscribeToTransactionExtrasFields)
 
         etCosmosMemo.inputtedTextAsFlow()
             .debounce(EDIT_TEXT_INPUT_DEBOUNCE)
@@ -252,7 +261,7 @@ class SendFragment : BaseStoreFragment(R.layout.fragment_send) {
                 info.cosmosMemoState?.viewFieldValue?.value != it
             }
             .onEach { store.dispatch(TransactionExtrasAction.CosmosMemo.HandleUserInput(it)) }
-            .launchIn(mainScope)
+            .launchIn(this@subscribeToTransactionExtrasFields)
 
         etHederaMemo.inputtedTextAsFlow()
             .debounce(EDIT_TEXT_INPUT_DEBOUNCE)
@@ -261,7 +270,7 @@ class SendFragment : BaseStoreFragment(R.layout.fragment_send) {
                 info.hederaMemoState?.viewFieldValue?.value != it
             }
             .onEach { store.dispatch(TransactionExtrasAction.HederaMemo.HandleUserInput(it)) }
-            .launchIn(mainScope)
+            .launchIn(this@subscribeToTransactionExtrasFields)
 
         etAlgorandMemo.inputtedTextAsFlow()
             .debounce(EDIT_TEXT_INPUT_DEBOUNCE)
@@ -270,7 +279,7 @@ class SendFragment : BaseStoreFragment(R.layout.fragment_send) {
                 info.algorandMemoState?.viewFieldValue?.value != it
             }
             .onEach { store.dispatch(TransactionExtrasAction.AlgorandMemo.HandleUserInput(it)) }
-            .launchIn(mainScope)
+            .launchIn(this@subscribeToTransactionExtrasFields)
     }
 
     private fun onCodeScanned(parsedQr: QrResult) {
@@ -343,12 +352,6 @@ class SendFragment : BaseStoreFragment(R.layout.fragment_send) {
             if (!hasFocus && etAmountToSend.text?.toString() == "") etAmountToSend.setText("0")
         }
 
-        etAmountToSend.inputtedTextAsFlow()
-            .debounce(EDIT_TEXT_INPUT_DEBOUNCE)
-            .filter { store.state.sendState.amountState.viewAmountValue.value != it && it.isNotEmpty() }
-            .onEach { store.dispatch(AmountActionUi.HandleUserInput(it)) }
-            .launchIn(mainScope)
-
         etAmountToSend.setOnImeActionListener(EditorInfo.IME_ACTION_DONE) {
             it.hideSoftKeyboard()
             it.clearFocus()

data/qr-scanning/src/main/java/com/tangem/data/qrscanning/repository/DefaultQrScanningEventsRepository.kt

@@ -6,9 +6,9 @@ import com.tangem.domain.qrscanning.models.QrResult
 import com.tangem.domain.qrscanning.models.SourceType
 import com.tangem.domain.qrscanning.repository.QrScanningEventsRepository
 import com.tangem.domain.tokens.model.CryptoCurrency
-import kotlinx.coroutines.flow.MutableSharedFlow
-import kotlinx.coroutines.flow.filter
-import kotlinx.coroutines.flow.map
+import kotlinx.coroutines.ExperimentalCoroutinesApi
+import kotlinx.coroutines.flow.*
+import kotlinx.coroutines.yield
 import java.math.BigDecimal
 import java.net.URLDecoder
 
@@ -16,15 +16,20 @@ internal class DefaultQrScanningEventsRepository : QrScanningEventsRepository {
 
     private data class QrScanningEvent(val type: SourceType, val qrCode: String)
 
-    private val scannedEvents = MutableSharedFlow<QrScanningEvent>()
+    private val scannedEvents = MutableSharedFlow<QrScanningEvent>(replay = 1)
 
     override suspend fun emitResult(type: SourceType, qrCode: String) {
         scannedEvents.emit(QrScanningEvent(type, qrCode))
     }
 
+    @OptIn(ExperimentalCoroutinesApi::class)
     override fun subscribeToScanningResults(type: SourceType) = scannedEvents
         .filter { it.type == type }
         .map { it.qrCode }
+        .onEach {
+            yield() // if we have more than one sub, we must allow them to collect emitted value
+            scannedEvents.resetReplayCache()
+        }
 
     override fun parseQrCode(qrCode: String, cryptoCurrency: CryptoCurrency): QrResult {
         val withoutSchema = stripSchema(qrCode, cryptoCurrency)

features/qr-scanning/impl/src/main/java/com/tangem/feature/qrscanning/QrScanningFragment.kt

@@ -4,6 +4,7 @@ import android.Manifest
 import android.content.pm.PackageManager
 import android.net.Uri
 import android.os.Bundle
+import android.view.View
 import androidx.activity.result.contract.ActivityResultContracts
 import androidx.compose.runtime.Composable
 import androidx.compose.runtime.DisposableEffect
@@ -15,6 +16,8 @@ import androidx.fragment.app.viewModels
 import androidx.lifecycle.Lifecycle
 import androidx.lifecycle.LifecycleEventObserver
 import androidx.lifecycle.compose.collectAsStateWithLifecycle
+import androidx.lifecycle.lifecycleScope
+import androidx.lifecycle.repeatOnLifecycle
 import com.google.accompanist.systemuicontroller.rememberSystemUiController
 import com.google.mlkit.vision.common.InputImage
 import com.tangem.core.ui.res.TangemTheme
@@ -25,6 +28,8 @@ import com.tangem.feature.qrscanning.navigation.QrScanningInnerRouter
 import com.tangem.feature.qrscanning.presentation.QrScanningContent
 import com.tangem.feature.qrscanning.viewmodel.QrScanningViewModel
 import dagger.hilt.android.AndroidEntryPoint
+import kotlinx.coroutines.delay
+import kotlinx.coroutines.launch
 import java.util.concurrent.ExecutorService
 import java.util.concurrent.Executors
 import javax.inject.Inject
@@ -69,11 +74,24 @@ internal class QrScanningFragment : ComposeFragment() {
 
     override fun onCreate(savedInstanceState: Bundle?) {
         super.onCreate(savedInstanceState)
-        viewModel.setRouter(innerRouter, galleryLauncher)
+        viewModel.setRouter(innerRouter)
         cameraExecutor = Executors.newSingleThreadExecutor()
         requestCameraPermission()
     }
 
+    override fun onViewCreated(view: View, savedInstanceState: Bundle?) {
+        super.onViewCreated(view, savedInstanceState)
+        viewLifecycleOwner.lifecycleScope.launch {
+            repeatOnLifecycle(Lifecycle.State.STARTED) {
+                viewModel.launchGalleryEvent
+                    .collect {
+                        galleryLauncher.launch(it.imageFilter)
+                        delay(timeMillis = 2000)
+                    }
+            }
+        }
+    }
+
     override fun onResume() {
         super.onResume()
         checkPermissionGranted()

features/qr-scanning/impl/src/main/java/com/tangem/feature/qrscanning/viewmodel/BaseQrScanningClickIntents.kt

@@ -1,6 +1,5 @@
 package com.tangem.feature.qrscanning.viewmodel
 
-import androidx.activity.result.ActivityResultLauncher
 import com.tangem.domain.qrscanning.models.SourceType
 import com.tangem.feature.qrscanning.navigation.QrScanningInnerRouter
 import kotlinx.coroutines.CoroutineScope
@@ -11,23 +10,14 @@ internal open class BaseQrScanningClickIntents {
     protected val router: QrScanningInnerRouter get() = _router
     protected val viewModelScope: CoroutineScope get() = _viewModelScope
     protected val source: SourceType get() = _source
-    protected val galleryLauncher: ActivityResultLauncher<String> get() = _galleryLauncher
 
     private var _router: QrScanningInnerRouter by Delegates.notNull()
     private var _viewModelScope: CoroutineScope by Delegates.notNull()
     private var _source: SourceType by Delegates.notNull()
 
-    private var _galleryLauncher: ActivityResultLauncher<String> by Delegates.notNull()
-
-    open fun initialize(
-        router: QrScanningInnerRouter,
-        source: SourceType,
-        galleryLauncher: ActivityResultLauncher<String>,
-        coroutineScope: CoroutineScope,
-    ) {
+    open fun initialize(router: QrScanningInnerRouter, source: SourceType, coroutineScope: CoroutineScope) {
         _router = router
         _viewModelScope = coroutineScope
         _source = source
-        _galleryLauncher = galleryLauncher
     }
 }

features/qr-scanning/impl/src/main/java/com/tangem/feature/qrscanning/viewmodel/QrScanningClickIntents.kt

@@ -5,11 +5,16 @@ import com.tangem.feature.qrscanning.presentation.QrScanningStateController
 import com.tangem.feature.qrscanning.presentation.transformers.DismissBottomSheetTransformer
 import com.tangem.utils.coroutines.CoroutineDispatcherProvider
 import dagger.hilt.android.scopes.ViewModelScoped
+import kotlinx.coroutines.channels.BufferOverflow
+import kotlinx.coroutines.flow.MutableSharedFlow
+import kotlinx.coroutines.flow.SharedFlow
 import kotlinx.coroutines.launch
 import javax.inject.Inject
 
 interface QrScanningClickIntents {
 
+    val launchGallery: SharedFlow<GalleryRequest>
+
     fun onBackClick()
 
     fun onQrScanned(qrCode: String)
@@ -17,6 +22,11 @@ interface QrScanningClickIntents {
     fun onGalleryClicked()
 }
 
+@JvmInline
+value class GalleryRequest(
+    val imageFilter: String,
+)
+
 @ViewModelScoped
 internal class QrScanningClickIntentsImplementor @Inject constructor(
     private val stateHolder: QrScanningStateController,
@@ -26,6 +36,11 @@ internal class QrScanningClickIntentsImplementor @Inject constructor(
 
     private var isScanned = false
 
+    override val launchGallery = MutableSharedFlow<GalleryRequest>(
+        extraBufferCapacity = 1,
+        onBufferOverflow = BufferOverflow.DROP_LATEST,
+    )
+
     override fun onBackClick() = router.popBackStack()
 
     override fun onQrScanned(qrCode: String) {
@@ -41,7 +56,7 @@ internal class QrScanningClickIntentsImplementor @Inject constructor(
     }
 
     override fun onGalleryClicked() {
-        galleryLauncher.launch(GALLERY_IMAGE_FILTER)
+        launchGallery.tryEmit(GalleryRequest(imageFilter = GALLERY_IMAGE_FILTER))
         if (stateHolder.value.bottomSheetConfig != null) {
             stateHolder.update(DismissBottomSheetTransformer())
         }

features/qr-scanning/impl/src/main/java/com/tangem/feature/qrscanning/viewmodel/QrScanningViewModel.kt

@@ -1,6 +1,5 @@
 package com.tangem.feature.qrscanning.viewmodel
 
-import androidx.activity.result.ActivityResultLauncher
 import androidx.lifecycle.SavedStateHandle
 import androidx.lifecycle.ViewModel
 import androidx.lifecycle.viewModelScope
@@ -14,6 +13,7 @@ import com.tangem.feature.qrscanning.presentation.transformers.DismissBottomShee
 import com.tangem.feature.qrscanning.presentation.transformers.InitializeQrScanningStateTransformer
 import com.tangem.feature.qrscanning.presentation.transformers.ShowCameraDeniedBottomSheetTransformer
 import dagger.hilt.android.lifecycle.HiltViewModel
+import kotlinx.coroutines.flow.SharedFlow
 import kotlinx.coroutines.flow.StateFlow
 import javax.inject.Inject
 
@@ -28,12 +28,12 @@ internal class QrScanningViewModel @Inject constructor(
     private val network: String? = savedStateHandle[NETWORK_KEY]
 
     val uiState: StateFlow<QrScanningState> = stateHolder.uiState
+    val launchGalleryEvent: SharedFlow<GalleryRequest> = clickIntents.launchGallery
 
-    fun setRouter(router: QrScanningInnerRouter, galleryLauncher: ActivityResultLauncher<String>) {
+    fun setRouter(router: QrScanningInnerRouter) {
         clickIntents.initialize(
             router = router,
             source = source,
-            galleryLauncher = galleryLauncher,
             coroutineScope = viewModelScope,
         )
         stateHolder.update(InitializeQrScanningStateTransformer(clickIntents, source, network))