이전에 just, of, from, range 등을 이용해서 간단하게 Observable 시퀀스를 만들고 subscribe하는 법에 대해서 배웠었죠?
이번에는 그런 간단한 방법이 아닌 조금 더 디테일 하게 Observable 시퀀스를 생성하는 법에 대해서 알아보도록 하겠습니다.
우선 맨 처음에 Observable에 대해서 알아볼 때 Observable이 방출하는 크게 네 가지의 이벤트가 있다고 했었습니다.
일반적인 이벤트를 방출하는 onNext
에러가 생겼을 때 방출하는 onError
모든 요소 방출이 끝났을 때 방출하는 onCompleted
Observable이 disposed 됐을 때 방출하는 onDisposed
바로 이런 이벤트들을 내가 원하는 시점에서 방출 시킬 수 있게 도와주는 것이 바로 create연산자 입니다!
create연산자를 사용해 자유 자재로 원하는 시점에 원하는 이벤트를 방출 시키는 Observable을 생성하고 subscribe해서 사용할 수 있습니다.
예를들어 create으로 API를 호출하는 Observable을 생성하여 결과를 onNext를 통해서 구독자에게 결과값은 전달한다던지 응용할 수 있습니다.
그런 점에 있어 create는 Rx에서 꼭 알아야 하는 요소입니다.