Skip to content

Instantly share code, notes, and snippets.

@AmaldevTA
Last active October 14, 2020 06:49
Show Gist options
  • Save AmaldevTA/6d7a0a1dd888ba29b4f4eca35cb46100 to your computer and use it in GitHub Desktop.
Save AmaldevTA/6d7a0a1dd888ba29b4f4eca35cb46100 to your computer and use it in GitHub Desktop.
implementation "io.reactivex.rxjava3:rxkotlin:3.0.0"
implementation 'io.reactivex.rxjava3:rxandroid:3.0.0'
implementation 'com.jakewharton.rxbinding4:rxbinding:4.0.0'
binding.buttonOne.clicks()
.buffer(4, TimeUnit.SECONDS, 5)
.filter { it.size == 5 }
.subscribe {
// code here
}
binding.buttonTwo.clicks()
.throttleFirst(500, TimeUnit.MILLISECONDS)
.observeOn(AndroidSchedulers.mainThread())
.subscribe{
// code here
}
Observable.mergeArray(
binding.button1.clicks().map { binding.button1 },
binding.button2.clicks().map { binding.button2 },
binding.button3.clicks().map { binding.button3 },
)
.throttleLast(500, TimeUnit.MILLISECONDS)
.observeOn(AndroidSchedulers.mainThread())
.subscribe {
val id = it.id
}
binding.customerSearch.textChanges()
.throttleLast(500, TimeUnit.MILLISECONDS)
.observeOn(AndroidSchedulers.mainThread())
.subscribe{
println("value - ${it.toString()}")
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment