RxJava

Rxjava프로그래밍이라는 책을 구매한지는 꽤 됐지만..이제야 제대로 다시 공부해보고자 합니다!! Rxjava는 리액티브 프로그래밍을 자바로 구현한 라이브러리라고 합니다데이터의 변화가 발생했을 때 변경이 발생한 곳에서 새로운 데이터를 보냄.(Push 방식)함수형 프로그

오늘은 Rxjava의 핵심 Observable을 공부해보려고 한다.내용이 많은 것 같아서 단일데이터와 다중일때를 나눠서 작성!RxJava 2.xObservable, Maybe, FlowableObservable은 옵서버 패턴을 구현하며, 옵서버 패턴은 객체의 상태 변화

💁단일 데이터가 아닌 경우는? 앞서 공부한 just()나 create()는 단일 데이터를 주로 다뤘다. 단일 데이터가 아닐 경우에는 fromXXX() 계열 함수를 사용!!🎈int \[] 배열 사용하기 int\[] 배열을 실제로 그대로 넣으면 올바른 실행결과가 나오지

Single 클래스는 오직 1개의 데이터만 발행데이터는 발행과 동시에 종료되며 OnNext()와 OnComplete() 함수가 onSuccess() 함수로 통합된 것Single 객체를 생성👉🏻 기존 Observable에서 첫 번째 값을 발행하면 onSuccess 이

차가운 Observable이란?옵서버가 subscribe() 함수를 호출하여 구독하지 않으면 데이터를 발행하지 않음. ⇒ lazy 접근법ex) 웹 요청, 데이터베이스 쿼리와 파일 읽기 등뜨거운 Observable이란?구독자가 존재 여부와 관계없이 데이터를 발행하는 Ob

Subject 클래스는 차가운 Observable을 뜨거운 Observable로 바꿔줌 💁 Observable의 속성과 구독자의 속성이 모두 존재Observable에서 발행한 마지막 데이터를 얻어올 수 있는 Subject클래스 1\. 처음 구독자가 subsc

가장 평범한 Subject 클래스로 오직 해당 시간에 발생한 데이터를 그대로 구독자에게 전달받음.

Subject 클래스처럼 차가운 Observable을 뜨거운 Observable로 변환Observable을 여러 구독자에게 공유할 수 있으므로 원 데이터 하나를 여러 구독자에게 동시에 전달 가능subscribe() 함수를 호출해도 아무 동작이 일어나지 않는다.conne

입력값을 어떤 함수에 넣어서 원하는 값으로 변환하는 함수입력 데이터와 그것을 변환해줄 함수를 이어주는 중개업자의 역할RxJava의 제네릭 함수형 인터페이스💁Function 인터페이스를 적용한 map() 함수 🎈 map 함수는 입력 타입과 반환 타입이 같을 필요가 없

Observable에서 원하는 데이터만 걸러내는 역할 👉🏻 CIRCLE로 끝나는 값만 출력🐥filter() 함수와 비슷한 함수들first(default) 함수 : Observable의 첫 번째 값을 필터, 만약 값 없이 완료되면 기본값 리턴last(defa

새로운 스레드를 생성하고 새로운 스레드를 만들어 어떤 동작을 실행하고 싶을 때 Schedulers.newThread()를 인자로 넣어주면 된다.뉴 스레드 스케줄러는 새로운 스레드를 생성하여 내가 원하는 동작을 처리하는 방법이다. 하지만 적극적으로 추천하는 방법은 아니다

subscirbeOn(A)를 호출했을 때는 데이터를 발해앟는 첫 줄이 스레드 A에서 실행. 이후에는 observeOn() 함수가 호출될 때까지 스레드 A에서 실행observeOn(B)를 호출하면 그다음인 두 번째 줄부터는 스레드 B에서 실행map()함수는 스레드 변경과