click listener in Kotlin coroutines using flow replacing RxJava

Question

I am currently using rxjava, rx binding for button click events, I want to change that to use kotlin coroutines Flow.

how can I convert this bellow code to use Flow please

   @Override
    public Observable getStartFuellingObservable() {
        return RxView.clicks(dataViewHolder.btnStartFuelling);
    }

Thanks R

user_11191424 · Answer

https://github.com/Kotlin-Android-Open-Source/MVI-Coroutines-Flow/blob/master/core-ui/src/main/java/com/hoc/flowmvi/core_ui/FlowBinding.kt#L57

@ExperimentalCoroutinesApi
@CheckResult
fun View.clicks(): Flow {
  return callbackFlow {
    setOnClickListener { safeOffer(it) }
    awaitClose { setOnClickListener(null) }
  }
}

user_9248718 · Answer

You can build a simple Kotlin Extension Function like the following:

fun View.clicks(): Flow = callbackFlow {
    val listener = View.OnClickListener {
        offer(Unit)
    }
    setOnClickListener(listener)
    awaitClose { setOnClickListener(null) }
}

This article is the source

It contains more info on how to have a similar API to RxJava and it's UI bindings. I think you could benefit from a read there

click listener in Kotlin coroutines using flow replacing RxJava

2 Answers