Rxjava -
Observer - Based on data view willl render (react) karega.
trotling -> making stream for execution (Means clicks event fire krege ek particular duration m taki same event again & again call n ho)
3 Major Component are there -
1) Observable
2) Observer
3) Operator
class MainActivity : AppCompatActivity() {
private var TAG:String = "MainActivity"
override fun onCreate(savedInstanceState: Bundle?) {
super.onCreate(savedInstanceState)
setContentView(R.layout.activity_main)
var btn_throttleFirst : Button = findViewById(R.id.btn_throttleFirst)
btn_throttleFirst.clicks()
.throttleFirst(15000,TimeUnit.MILLISECONDS)
.subscribe {
Log.d(TAG,"throttleFirst duration : 15000 MLS")
}
simpleObserver()
}
private fun simpleObserver(){
var list = listOf<String>("member 1","member 2","member 3")
val observable = io.reactivex.rxjava3.core.Observable.fromIterable(list)
observable.subscribe(object : io.reactivex.rxjava3.core.Observer<String>{
override fun onSubscribe(d: Disposable) {
Log.d(TAG,"onSubscribe")
}
override fun onError(e: Throwable) {
Log.d(TAG,"onError")
}
override fun onComplete() {
Log.d(TAG,"onComplete")
}
override fun onNext(t: String) {
Log.d(TAG,"onNext")
}
})
}
}
output -
throttleFirst duration : 15000 MLS
