Rxjava Observable

Observable

현재는 관찰되지 않았지만 앞으로 관찰할 대상

 

RxJava의 Observable은 세가지의 알림을 구독자에게 전달한다.

onNext

Observable은 새로운 항목들을 배출할 때마다 이 메서드를 호출한다. 이 메서드는 Observable이 배출하는 항목을 파라미터로 전달 받는다.

onError

Observable은 기대하는 데이터가 생성되지 않았거나 다른 이유로 오류가 발생할 경우 오류를 알리기 위해 이 메서드를 호출한다. 이 메서드가 호출되면 onNext나 onCompleted는 더 이상 호출되지 않는다. onError 메서드는 오류 정보를 저장하고 있는 객체를 파라미터로 전달 받는다.

onCompleted

오류가 발생하지 않았다면 Observable은 마지막 onNext를 호출한 후 이 메서드를 호출한다.

 

 

Observable을 생성할때는 직접 인스턴스를 만들지 않고 정적 팩토리 함수를 호출한다.

RxJava 버전	팩토리 함수
버전 1의 기본 팩토리 함수	create( ), just( ), from( )
버전 2의 추가 팩토리 함수	fromArray( ), fromIterable( ), fromCallable( ), fromFuture( )
기타 팩토리 함수	interval( ), range( ), timer( ), defer( )