Pattern/Funtional (5) 썸네일형 리스트형 RxJava 연산자 📚 RxJava에서 연산자란? RxJava에서 연산자란 함수이다. 연산자를 이용하여 데이터를 생성하고 통지하는 Flowable이나 Observerble 등의 생산자를 생성할 수 있다. 생산자에서 통지한 데이터를 다양한 연산자를 통하여 데이터를 가공하여 결과값을 만들어 낼 수 있다. 🙋♂️ Flowable, Observable 생성 연산자 interval 지정한 시간 간격마다 0부터 시작하는 숫자를 통지한다. (Long Type) InitialDelay 파라미터를 사용하여 최초 대기 시간에 대한 대기 시간을 지정할 수 있다. 완료 없이 계속 통지한다. 호출한 스레드와는 별도의 스레드에서 사용된다. Polling 용도의 작업을 사용할 때 활용될 수 있다. range(n, m) 지정한 값(n)부터 m개의 숫.. Flowable과 Observable 🙋♂️ Flowable과 Observable의 비교 1. Flowable Reactiver Streams 인터페이스를 구현 Subscriber에서 데이터를 처리 데이터 개수를 제어하는 배압 기능 존재 Subscription으로 전달 받는 데이터 개수 제어 Subscription으로 구독 해지 2. Observable Reactiver Streams 인터페이스를 구현 X Observer에서 데이터를 처리 데이터 개수를 제어하는 배압 기능 X 배압 기능이 없기 때문에 데이터 개수를 제어 X Disposable로 구독 해지 3. 배압이란? Flowable에서 데이터를 통지하는 속도가 Subscriber에서 통지된 데이터를 전달 받아 처리하는 속도 보다 빠를 때 밸런스를 맞추기 위해 통지량을 제어하는 기능을 .. Reactive Streams 🙋♂️ API Components 1. Publisher (생산자) 데이터를 생성하고 통지한다. subscribe : 소비자를 등록할 때 호출 2. Subscriber (소비자) 통지된 데이터를 전달받아서 처리한다. onSubscribe : 데이터를 최초 통지할 때 호출 onNext : 데이터를 통지할 때 마다 호출 onError : 데이터 통지에서 에러가 발생했을 때 호출 onComplete : 데이터 통지가 완료 되었을 때 호출 3. Subscription 구독 자체를 의미, 전달 받을 데이터의 개수를 요청하고 구독을 해지한다. request : 데이터 개수 요청 cancel : 요청 취소 4. Processor Publisher와 Subscriber의 모든 기능이 있음. 🙋♂️ Publisher.. Single, Maybe, Completable 보호되어 있는 글입니다. RxJava Publisher, Subscriber Reactive Streams은 데이터를 만들어 통지하는 Publisher와 통지된 데이터를 받아 처리하는 Subscriber로 구성된다. Subscriber가 Publisher를 구독하면 Publisher가 통지한 데이터를 Subscriber가 받을 수 있다. Publisher : 데이터를 통지하는 생산자 Subscriber 데이터를 받아 처리하는 소비자 Publisher가 데이터를 통지하고 SubScriber는 데이터를 받을때까지의 흐름 1. Publisher의 통지 준비 2. Subscriber에게 통지 3. Subscriber는 받고자하는 데이터 개수를 요청(만약 데이터 개수를 요청하지 않으면 생성자는 요청을 기다리는 상태이므로 통지를 시작할 수 없음) 4. Publisher는 데이터를 만들어 S.. 이전 1 다음