Hey, I am trying to implement a search functionality that will hit the server endpoint. I am using

SharedFlow

,

collectLatest

and

debounce

so the endpoint won't be hit every time there is a text change. However,

collectLatest

is being called many times. why? and how can I fix it? full code

searchText
                .debounce(1000)
                .distinctUntilChanged { prev, next -> prev != next }
                .filter { it.isNotEmpty() }
                .sample(500)
                .collectLatest {
                    Log.d("Remon", "search collect - value: $it")
                }

Are you sure that

distinctUntilChanged

has valid check? This lambda should check for elements equality and your current implementation does the opposite.

I am not sure

I think this should be enough

searchText
                .debounce(1000)
                .distinctUntilChanged()
                .filter { it.isNotEmpty() }
                .collectLatest {
                    Log.d("Remon", "search collect - value: $it")
                }

still not working.. the collect block is called ~5 times

I checked this code and for me it seems to work. Can you give more context? How this flow is used? What is your expected behaviour?

I found the issue, for me I was calling the whole block of code many times

No problem K