본문 바로가기
반응형

Reactive programming6

RxJava, RxKotlin - timer [출처 - RxJava 프로그래밍 : 리액티브 프로그래밍 기초부터 안드로이드 까지 한번에] 본 글은 'RxJava 프로그래밍 : 리액티브 프로그래밍 기초부터 안드로이드 까지 한번에' 를 학습하면서 정리한 글입니다 마블다이어그램 참고 - http://reactivex.io/RxJava/javadoc/io/reactivex/Flowable.html#timer-long-java.util.concurrent.TimeUnit- timer는 interval 함수와 유사하지만 한번만 실행하는 함수입니다. 일정 시간 지난 후 한번만 발행하고 onComplete 이벤트를 발생시킵니다. timer의 원본 code를 보면 @SchedulerSupport(SchedulerSupport.COMPUTATION) public st.. 2019. 11. 20.
RxJava,RxKotlin - Interval [출처 - RxJava 프로그래밍 : 리액티브 프로그래밍 기초부터 안드로이드 까지 한번에] 본 글은 'RxJava 프로그래밍 : 리액티브 프로그래밍 기초부터 안드로이드 까지 한번에' 를 학습하면서 정리한 글입니다 마블다이어그램 참고 - http://reactivex.io/RxJava/javadoc/io/reactivex/Flowable.html#interval-long-long-java.util.concurrent.TimeUnit- interval() 함수는 일정 시간 간격으로 데이터 흐름을 생성합니다. interval 함수는subscribe한 시간 부터 주어진 시간 간격으로 0부터 1씩 증가하는 Long 객체(기본형인 long 값이 아니라 래퍼 클래스인 Long 객체입니다) 객체를 발행합니다. 주로 사.. 2019. 11. 20.
RxJava,RxKotlin - Observable (5) - ConnectableObservable [출처 - RxJava 프로그래밍 : 리액티브 프로그래밍 기초부터 안드로이드 까지 한번에] 본 글은 'RxJava 프로그래밍 : 리액티브 프로그래밍 기초부터 안드로이드 까지 한번에' 를 학습하면서 정리한 글입니다 마블다이어그램참고 - http://reactivex.io/RxJava/javadoc/io/reactivex/subjects/Subject.html ConnectableObservble은 차가운 Observable을 뜨거운 Observable로 변환합니다. Subject 처럼 말이죠. 이 ConnectableObservble은 Observable을 여러 구독자에게 공유할 수 있으므로 원 데이터 하나를 여러 구독자에게 동시에 전달할 때 사용합니다. 마블다이어그램으로 설명해 드리겠습니다. 이 Conn.. 2019. 10. 24.
RxJava,RxKotlin - Observable (4) - Subject [출처 - RxJava 프로그래밍 : 리액티브 프로그래밍 기초부터 안드로이드 까지 한번에] 본 글은 'RxJava 프로그래밍 : 리액티브 프로그래밍 기초부터 안드로이드 까지 한번에' 를 학습하면서 정리한 글입니다 앞선 글에서 Subject는 차가운 Observable은 뜨거운 Observable로 바꿔준다고 소개했습니다. Subject의 특징은 Observable의 속성과 구독자의 속성을 모두 가지고 있다는 점입니다. 즉 데이터를 발행할 수 도 있고, 데이터를 받아서 치러할 수 도 있다는 말이 됩니다. 이런 Subject에서 제공하는 각 클래스를 알아 보겠습니다. AsyncSubject AsyncSubject는 Observable에서 발행한 마지막 데이터를 얻어올 수 있는 Subject 입니다. 마지막 .. 2019. 10. 22.
반응형