Hello All, I'm trying to build a Search functionality using BroadcastChannel api in Coroutine.

# coroutines

[Deepak Gahlot]

Hello All, I'm trying to build a Search functionality using BroadcastChannel api in Coroutine.

[Deepak Gahlot]

In the ViewModel i have following code

[Deepak Gahlot]

@ExperimentalCoroutinesApi
@VisibleForTesting
val queryChannel = ConflatedBroadcastChannel<String>()

[Deepak Gahlot]

@FlowPreview
@ExperimentalCoroutinesApi
@VisibleForTesting
fun userQuerySearch(query: String) {
    viewModelScope.launch {
        queryChannel
            .asFlow()
            .debounce(SEARCH_DELAY_MS)
            .mapLatest {
                Log.i("mylog", "userQuerySearch: $it")
                if (it.length >= MIN_QUERY_LENGTH) {
                    questionnaireRepoImp.commoditySearch(query = query, sLiveData = searchMasterData)
                    searchMasterData.postValue(Resource.Loading())
                } else {
                    searchMasterData.postValue(Resource.Success(MasterData()))
                }
            }
    }

[Deepak Gahlot]

And from my UI which is a Composable function i update the Channel and call the function for search

[Deepak Gahlot]

corotineScope.launch(<http://Dispatchers.IO|Dispatchers.IO>) {
    questionnaireViewModel.queryChannel.send(value.value)
    questionnaireViewModel.userQuerySearch(value.value)
}

[Deepak Gahlot]

What i'm seeing that queryChannel doe not receive any text input that is being send from the UI

[Deepak Gahlot]

But if is use something like

[Deepak Gahlot]

queryChannel.consumeEach {
    Log.i("mylog", "userQuerySearch: $it")
}

In see that the inputs are being received from the UI

[Deepak Gahlot]

I'm doing a wrong conversion to flow ?

[Dominaezzz]

Why do you pass query as a function argument? You already have the channel, no?

[Dominaezzz]

try removing debounce

[MiSikora]

You don’t collect any events. You need to use either launchIn or collect on your Flow.

[Deepak Gahlot]

@Dominaezzz you are right, i have made that change.