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

# coroutines

[Remon Shehata]

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")
                }

[Damian Baczyński]

Are you sure that distinctUntilChanged has valid check? This lambda should check for elements equality and your current implementation does the opposite.

[Remon Shehata]

I am not sure

[Remon Shehata]

I changed it so prev == next ... same result..

[Damian Baczyński]

I think this should be enough

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

[Remon Shehata]

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

[Damian Baczyński]

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?

[Remon Shehata]

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

[Remon Shehata]

thank you so much for your help

[Damian Baczyński]

No problem K