Observable Examples

        
        val anyList: List<Any> = listOf("One", 2, "Three", "Four", 4.5, "Five", 6.0f)
        
        val observable: Observable<Any> = anyList.toObservable()

        val observer: Observer<Any> = object : Observer<Any> {
            override fun onComplete() {
                log("All Completed")
            }
            override fun onSubscribe(d: Disposable) {
                log("Suscribed to $d")
            }
            override fun onNext(t: Any) {
                log("Next $t" + " / " + t::class)
            }
            override fun onError(e: Throwable) {
                log("Error Occured $e")
            }
        }
        
        observable.subscribe(observer)