[RxJava] Observable - (2)

💁단일 데이터가 아닌 경우는 어떻게 할까요, 앞서 공부한 just()나 create()는 단일 데이터를 주로 다루어 보았는데요. 이번에는 단일 데이터가 아닐 경우에 어떻게 사용하는지 즉 fromXXX() 계열 함수에 대해 알아보도록 하겠습니다. fromArray() 함수 Integer[] arr = {100,200,300}; Observable source = Observable.fromArray(arr); source.subscribe(System.out::println); 🎈int [] 배열 사용하기 int[] 배열을 실제로 그대로 넣으면 올바른 실행결과가 나오지 않습니다. ⇒ toIntegerArray()를 사용해야 합니다. int[] intArray = {400,500,600}; Observabl..

• format_list_bulleted RxJava
• · 2022. 10. 21.
• textsms

[RxJava] Observable - (1)

오늘은 Rxjava의 핵심 Observable을 공부해보려고 합니다. 내용이 많아서 단일 데이터와 다중일 때를 나눠서 공부해보도록 하겠습니다~! RxJava 2.x Observable, Maybe, Flowable Observable 클래스 Observable은 옵서버 패턴을 구현하며, 옵서버 패턴은 객체의 상태 변화를 관찰하는 관찰자 목록을 객체 등록. 상태 변화가 있을 때마다 메서드를 호출하여 객체가 직접 목록의 각 옵서버에서 변화를 알려준다. 💡Observable이 전달하는 세 가지의 알림 onNext : Observabled이 데이터의 발행을 알림 onComplete : 모든 데이터의 발행을 완료했음을 알리고, 단 한 번만 발생하며 발생한 후에는 더 이상 OnNext 이벤트가 발생해서는 안된다. ..

• format_list_bulleted RxJava
• · 2022. 10. 21.
• textsms

[RxJava] 기본 개념

블로그 이전하는김에 점점 까먹고 있는 RxJava 다시 한 번 공부해보도록 하려고 합니다. RxJava를 깊게 공부하기 전 간단한 개념 먼저 살펴보도록 하겠습니다. 리액티브 프로그래밍 데이터의 변화가 발생했을 때 변경이 발생한 곳에서 새로운 데이터를 보냄.(Push 방식) 함수형 프로그래밍의 지원이 필요 멀티 스레드 환경에서 사용할시 데드락과 동기화 문제 발생할 수 있음. Observable.just("hello") .subscribe(System.out::println); Observable 클래스 데이터의 변화가 발생하는 데이터 소스 just()함수 Observable 선언 방식 Subscribe() 함수 Observable을 구독하며 Observable은 subscribe() 함수를 호출해야 변화한..

• format_list_bulleted RxJava
• · 2022. 10. 21.
• textsms