if I have this code ```private fun SearchScreenEvent.eventToUsecase(): Flow<SearchState> { ...

# flow

[Mohamed Ibrahim]

if I have this code

private fun SearchScreenEvent.eventToUsecase(): Flow<SearchState> {
    return when (this) {
        is SearchClicked -> searchUsecase(this.query)
        is SearchQueryChanged ->
            flowOf(this.query)
                .debounce(5000)
                .flatMapConcat { searchUsecase(this.query) }
    }
}

why debounce is not working here

[Matti MK]

Not quite sure, but I’m guessing you create a new flow on every SearchQueryChanged

[Mohamed Ibrahim]

this is true, back then with RxJava I was using switchMap with publish to resolve this,
here is How I subscribe my events

events
    .flatMapConcat { it.eventToUsecase() }
    .onEach { _states.value = it }
    .launchIn(viewModelScope)

[Mohamed Ibrahim]

I just want to control the text change events, so it debounce(someTime) and only take the latest emission

[ephemient]

debounce on a single-element flow does nothing, you need it to live outside

[ephemient]

it would be easier if you had two separate flows to start with,

[ephemient]

merge(
    searchClicks,
    searchQueryChanges.debounce(5000L)
)

[ephemient]

although you will have to grab the latest searchQuery when handling a searchClick, as the last SearchQueryChanged may be pending a debounce when this produces a SearchClicked

[Mohamed Ibrahim]

Thank you that make since 👍