Simple Observable

간단하게 Observable 을 테스트 해보자. 

 

var list:List<Any> = listOf("Alpha", "Beta", "Gamma", "Delta", "Epsilon")
var observable : Observable<Any> = list.toObservable()

@Test
fun simpleObservable() {
        observable.subscribeBy(
                   onNext = {
                         println("it = $it")
                   },
                   onError = {
                         it.printStackTrace()
                   },
                   onComplete = {
                          print("Complete ! ")
                    }
         )
}

 

결과 

코드를 순서대로 설명하자면,

 

1. 리스트 생성

2. 생성한 리스트로 observable 인스턴스 생성 

3. observable 인스턴스 구독 

 

일단 observable을 구독 했으므로 변경사항이  onNext 로 푸시가 되고,

모든 데이터가 푸쉬 되고, Complete 가 호출 되었다.

에러가 발생하면 onError 가 호출 된다.