THIS IS ELLIE

Subject 주제(subject)는 옵저버나 Observable처럼 행동하는 ReactiveX의 일부 구현체에서 사용 가능한 일종의 교각 혹은 프록시라고 볼 수 있는데, 그 이유는 주제는 옵저버이기 때문에 하나 이상의 Observable을 구독할 수 있으며 동시에 Observable이기도 하기 때문에 항목들을 하나 하나 거치면서 재배출하고 관찰하며 새로운 항목들을 배출할 수도 있다. 하나의 주제는 하나의 Observable을 구독하면서, (Observable이 "차가운" Observable인 경우 즉, 옵저버가 구독을 시작하기 전까지 항목들의 배출을 지연시키는 Observable일 경우)Observable이 항목들을 배출시키도록 동작시킨다. 그 결과로 인해 원래는 "차가운" Observable이었던 주..

Single - Single은 Obvservable의 한 형태이지만, Observable처럼 존재하지 않는 곳에서부터 무한대까지의 임이의 연속된 값들을 배출하는 것과는 달리, 항상 한 가지 값 또는 오류 알림 둘 중 하나만 배출한다. - Single을 구독할 때는 Observable을 구독할 때 사용하는 세 개의 메서드(onNext, onError, 그리고 onCompleted) 대신 다음의 두 메서드만 사용할 수 있다. - onSuccess - Single은 자신이 배출하는 하나의 값을 이 메서드를 통해 전달한다 - onError - Single은 항목을 배출할 수 없을 때 이 메서드를 통해 Throwable 객체를 전달한다 - Single은 이 메서드 중 하나만 그리고, 한 번만 호출한다. 메서드가 ..

Scheduler - Observable 연산자 체인에 멀티스레딩을 적용하고 싶다면, 특정 스케줄러를 사용해서 연산자를 실행하면 된다. - ReactiveX의 일부 Observable연산자는 사용할 스케줄러를 파라미터로 전달 받기도 하는데, 이 연산자들은 자신이 처리할 연산의 일부 또는 전체를 전달된 스케줄러 내에서 실행한다. - 기본적으로, Observable과 연산자 체인은 스케줄러를 통해 동작하고 Subscribe메소드가 호출되는 스레드를 사용해서 옵저버에게 알림을 보낸다. - SubscribeOn 연산자는 다른 스케줄러를 지정해서 Observable이 처리해야 할 연산자들을 실행 시킨다. 그리고 ObserveOn 연산자는 Obserable이 옵저버에게 알림을 보낼때 사용 할 스케줄러를 명시한다. ..

Operators Chaining Operators - 거의 모든 연산자들은 Observable상에서 동작하고 Observable을 리턴한다. - 이 접근 방법은 연산자들을 연달아 호출할 수 있는 연산자 체인을 제공한다. - 연산자 체인에서 각각의 연산자는 이전 연산자가 리턴한 Observable을 기반으로 동작하며 동작에 따라 Observable을 변경한다. - 먼저 실행된 연산자가 리턴한 Observable을 기반으로 다음 연산자가 동작하기 때문에 Observable은 순서대로 실행되야한다. Operators By Category Creating Observables - Create — 직접적인 코드 구현을 통해 옵저버 메서드를 호출하여 Observable을 생성한다 - Defer — 옵저버가 구독하..

Observable - ReactiveX에서 옵저버는 Observable을 구독한다. - 옵저버는 Obervable이 배출하는 하나 또는 연속된 아이템에 반응한다. (concurrent operations을 가능하게 함) Observable이 객체를 배출할 때까지 기다릴 필요 없이 어떤 객체가 배출되면 그 시점을 감시하는 관찰자 옵저버를 통해 배출 알림을 받기 때문이다. Establishing Observers - 일반적인 메소드 호출 흐름 - 메소드를 호출한다. - 메소드가 리턴한 값을 변수에 저장한다. - 결과 값을 가진 변수를 통해 필요한 연산을 처리한다. - 비동기 모델에서의 메소드 호출 흐름 - 비동기 메소드 호출로 결과를 리턴받고 필요한 동작을 처리하는 메소드를 정의한다. - Observabl..