I have a MutableStateFlow<String> which passes an argument to a suspend fun. On each latest one I want to launch a suspend fun on the IO dispatcher, however if it emits a new value before the previous suspend function is complete, it should cancel that one and launch the suspend fun with the new argument. How should I do this?

we did it like this:

class TaskSearchDelegate(
    private val repository: TaskRepository,
) : SearchDelegate<TaskModel> {

    override lateinit var searchPagingFlow: Flow<PagingData<TaskModel>>

    private lateinit var uiCaller: UiCallerImpl
    private val searchTextFlow = MutableStateFlow("")

    override fun init(uiCaller: UiCallerImpl) {
        this.uiCaller = uiCaller
        searchPagingFlow = searchTextFlow.debounce(SearchDelegate.debounceDelayMs)
            .flatMapLatest {
                repository.searchTasks(it)
            }.cachedIn(uiCaller.scope)
    }

    override fun searchByText(text: String) {
        searchTextFlow.value = text
    }
}