Reactive Programming in Kotlin

Take operators (take, takeLast, takeWhile, and takeUntil)

The take operators work in exactly the opposite way than the skip operators. Let's take an example of them one by one and understand how they work:

 fun main(args: Array<String>) { val observable1 = Observable.range(1,20) observable1 .take(5)//(1) .subscribe(object:Observer<Int> { override fun onError(e: Throwable) { println("Error $e") } override fun onComplete() { println("Complete") } override fun onNext(t: Int) { println("Received $t") } override fun onSubscribe(d: Disposable) { println("starting skip(count)") } }) val observable2 = Observable.interval(100,TimeUnit.MILLISECONDS) observable2 .take(400,TimeUnit.MILLISECONDS)//(2) .subscribe( object:Observer<Long> { override fun onError(e: ...