본문 바로가기
반응형

ReactiveX (Rx)7

RxJava에 대한 기본적인 개념 (Stream, Reactive Programming, Reactive Stream) Stream 이란? 데이터의 변화가 이루어지며 생긴 이벤트들을 관찰자들에게 알려주는 객체입니다 한마디로 시간에 따라 정렬되어 진행 중인 이벤트 흐름이라고 생각하시면 편합니다 Rx에서는 스트림의 방출되는 이벤트로 onNext, onError, onComplete 등이 있고 스트림을 연산자로 변형하여 사용할 수 있습니다 Reactive Programming 이란? Reactive Programming은 데이터 흐름과 전달에 관한 프로그래밍 패러다임입니다 여기서 패러다임이란 사람들의 견해나 사고를 규정하는 인식 체계를 뜻합니다, 프로그래밍 패러다임은 프로그래밍을 인식하는 방식이나 방향을 뜻합니다 이해하기 쉽게 말하자면 Reactive Programming은 데이터의 흐름을 먼저 정의하고 데이터가 변경되었을 때.. 2022. 4. 4.
[RxJava] ConnectableObservable, Subject에 대해 알아보자 ConnectableObservable ConnectableObservable는 뜨거운 Observable을 만들기 위한 방법 중 하나입니다 뜨거운 Observable과 차가운 Observable에 대해 궁금하시다면 아래 글을 확인해 주세요 2022.03.30 - [Reactivex (Rx)] - [RxJava] Cold Observable, Hot Observable에 대해 알아보자 [RxJava] Cold Observable, Hot Observable에 대해 알아보자 Cold Observable 이란? 일반적으로 사용하는 Observable이 바로 Cold Observable이다 Subscribe(구독)할 때 데이터를 발행해줍니다 (여기서 말하는 Subscribe와 Subscriber은 다른 겁니다.. 2022. 4. 4.
[RxJava] Cold Observable, Hot Observable에 대해 알아보자 Cold Observable 이란? 일반적으로 사용하는 Observable이 바로 Cold Observable이다 Subscribe(구독)할 때 데이터를 발행해줍니다 (여기서 말하는 Subscribe와 Subscriber은 다른 겁니다!!) Cold 생산자는 1개의 소비자와 구독 관계를 맺기 때문에 생산자가 통지하는 데이터의 타임라인이 구독할 때 생성되고 처리가 시작됩니다 이름 그대로 cold라서 차갑게 얼어붙어있어 구독을 하면(녹이면) 데이터가 발행이 된다 이런 식으로 이해하시면 될 것 같습니다 Hot Observable 이란? Hot Observable은 Cold Observable의 반대입니다, Cold Observable을 ConnectableObservable과 Subject를 이용해 Hot O.. 2022. 3. 30.
[RxJava] 생산자와 소비자, 데이터 스트림이란? (Observable, Observer, Flowable, Subscriber) 이번 글을 자주 나오는데 자꾸 헷갈려서 정확한 개념 정리를 위해 만들게 되었습니다 저만 헷갈린 거 아니죠?ㅎ;; 먼저 RxJava는 기본적으로 데이터를 만들고 발행하는 생산자와 발행된 데이터를 받고 처리하는 소비자로 구성되어 있습니다 생산자는 데이터 스트림의 데이터들을 발행하는 역할을 합니다, 생산자를 소비자가 구독하게 되어 생산자가 발행하는 데이터를 소비자가 받을 수 있게 됩니다 그럼 여기서 데이터 스트림과 소비자는 무엇일까요? 먼저 데이터 스트림은 데이터나 이벤트가 들어오는 통로입니다 (데이터가 흐르는 강이라고 비유할 수 있겠네요) 소비자는 말 그대로 생산자의 데이터를 사용하는 주체입니다 이름 내용 생산자 데이터 스트림의 데이터를 발행하는 역할 소비자 생산자의 데이터를 사용하는 주체 데이터 스트림 데.. 2022. 3. 29.
반응형