We learned about the Observable.create method in the previous chapter, but to make things less complicated, let's have a quick recap, and then we can continue with Flowable.create. Take a look at the following piece of code:
fun main(args: Array<String>) { val observer: Observer<Int> = object : Observer<Int> { override fun onComplete() { println("All Completed") } override fun onNext(item: Int) { println("Next $item") } override fun onError(e: Throwable) { println("Error Occured ${e.message}") } override fun onSubscribe(d: Disposable) { println("New Subscription ") } }//Create Observer val observable: Observable<Int> = Observable.create<Int> {//1 for(i in 1..10) { it.onNext(i) } it.onComplete() } observable.subscribe(observer) ...
