fun countDownCoroutines(total:Int,onTick:(Int)->Unit,onFinish:()->Unit, scope: CoroutineScope = GlobalScope):Job{ return flow{ for (i in total downTo 0){ emit(i) delay(1000) } }.flowOn(Dispatchers.Default) .onCompletion { onFinish.invoke() } .onEach { onTick.invoke(it) } .flowOn(Dispatchers.Main) .launchIn(scope) } 

 inline fun <reified T> fromJson(json: String): T? { return try { val type = object : TypeToken<T>() {}.type return Gson().fromJson(json, type) } catch (e: Exception) { null } } fun Any.toJson():String{ return Gson().toJson(this) } 

 private val stateFlow = MutableStateFlow("") private fun searchFilter(str:String){ stateFlow .debounce(400) .filter { it.isNotEmpty() } .distinctUntilChanged() .flatMapLatest { getFlowList(it) } .catch { print(it.message) } .flowOn(Dispatchers.Default) .onEach { print(it.toString()) }.flowOn(Dispatchers.Main) .launchIn(lifecycleScope) } 

 inline fun View.setThrottleListener(delayMillis: Long = 1000L,crossinline onClick: () -> Unit) { this.setOnClickListener { this.isClickable = false onClick() this.postDelayed({ this.isClickable = true }, delayMillis) } }