본문 바로가기
[RxJava] #5 스케줄러 5.1. 스케줄러 개념 배우기 -스케줄러는 스레드를 지정할 수 있게 해준다.단순히 새로운 스레드를 생성하거나 기존의 Executors 를 활용하는 것을 넘어 새로운 방식으로 우리를 맞이한다.그동안 어렵게 다루어야 했던 비동기 프로그래밍이 간결한 코드로 다시 태어난다. -String[] objs = {“1-S”, “2-T”, “3-P”}; Observable source = Observable.fromArray(objs) .doOnNext(data -> Log.v(“Original data = “ + data)) .subscribeOn(Schedulers.newThread()) // 발행부터의 thread 지정 .observeOn(Schedulers.newThread()) // 불리는 순간부터의 threa.. 2019. 6. 7.
[RxJava] #4 리액티브 연산자의 활용 4.1. 생성 연산자 -생성 연산자의 역할은 데이터 흐름을 만드는 것이다.간단하게 Observable, Single, Maybe 객체 등을 만든다고 생각하면 된다. 4.1.1. interval() 함수 -일정 시간 간격으로 데이터 흐름을 생성한다.주어진 시간 간격으로 0부터 1씩 증가하는 Long 객체를 반환한다. -interval() 함수는 기본적으로 영원히 지속 실행되기 때문에 폴링 용도로 많이 사용된다.수행은 RxComputationalThreadPool 에서 수행된다.interval 값이 초기 지연값으로도 활용된다. 4.1.2. timer() 함수 -interval 함수와 유사하지만 한 번만 실행하는 함수.일정 시간이 지난 후에 한 개의 데이터를 발행하고 onComplete() 이벤트가 발생한다... 2019. 6. 5.
[RxJava] #3 리액티브 연산자 입문 - ReactiveX 문서의 연산자 부분을 살펴보면 다양한 연산자(operator)함수가 존재한다. 이 연산자들은 버전이 높아지면서 계속 늘고 있다. 이 연산자들을 모두 알아야 리액티브 프로그래밍을 할 수 있는 것은 아니다. - for, if while 문처럼 프로그래밍 언어에서 제공하는 키워드들을 사용하는 대신 RxJava 의 연산자로 비동기 프로그래밍에 필요한 주요 로직을 만들 수 있다. - 리액티브 연산자의 특징은 언어 특성과 크게 연관이 없다. 리액티브 연산자는 함수라고 한다. 형식만 놓고 보면 Observable 등의 클래스에 포함되어 있으므로 자바 관점에서는 메서드이다. 하지만 함수형 프로그래밍의 원리에 따르면 리엑티브 연산자는 부수 효과가 없는 순수 함수(pure function)이다. - .. 2019. 6. 4.
[RxJava] #2 Observable 처음 만들기 - Observable 은 데이터 흐름에 맞게 알림을 보내 구독자가 데이터를 처리할 수 있도록 한다. RxJava 프로그래밍은 Observable 에서 시작해 그것으로 끝난대고 해도 과언이 아닐 정도로 중요한 개념이다. - Rajava 1.x 에서는 데이터 소스를 Observable 과 Single 클래스로 구성했다. RxJava 2 에서는 Observable 클래스를 상황에 맞게 세분화해 각각 Observable, Maybe, Flowable 로 나뉘었고, Single 도 그대로 존재한다. - Maybe 클래스는 Reduce() 함수나 firstElement() 함수와 같이 데이터가 발행될 수 있거나 혹은 발행되지 않고도 완료되는 경우를 의미한다. - Flowable 클래스는 Observable 에서 .. 2019. 6. 3.
반응형