Subscribing to a observable

Subscribing to an observable using Subscribe

Code

        val observableMovieList = listOf( episodeI, episodeII, episodeIII ).toObservable()

        observableMovieList.subscribe{
            println("Result-> $it")
        }

output

Result-> The Phantom Menace
Result-> Attack of the Clones
Result-> Revenge of the Sith

Subscribing to an observable using SubscribeBy

Code

        val observableMovieList = listOf( episodeI, episodeII, episodeIII ).toObservable()

        observableMovieList.subscribeBy(
            onNext = {
                println("Result-> $it")
                     },
            onError = {
                println("ErrorMessage-> ${it.localizedMessage}")
            },
            onComplete = {
                println("Emissions are complete")
            }
        )    

output

Result-> The Phantom Menace
Result-> Attack of the Clones
Result-> Revenge of the Sith
Emissions are complete