RxSwift ReactiveX 라이브러리를 swift 언어로 구현한 것 RxSwift Github 사용 이유 단순하고 직관적인 코드 작성 깔끔한 비동기 코드 참고
전달하는 이벤트 error (notification)completed (notification)next (emmission)observerbles - 이벤트의 순서 정의 observer - subscriberparam인 배열에 있는 요소를 순서대로 방출한 뒤 comp
onDisposed observable 이 전달하는 이벤트가 X 리소스가 해제되는 시점에 자동으로 호출됨 가능하다면 리소스 정리를 직접 해주는게 좋음 리소스 해제 1. 직접 해제 하기 2. DisposeBag 사용 1번 방법보다 더 권장됨 subscribe 가
Operators > Example let bag = DisposeBag() > Observable.from([1, 2, 3, 4, 5, 6, 7, 8, 9]) .take(5) // 처음 5개의 요소만 전달 .filter { $0.isMultiple(of: 2) }
Subject > observable 인 동시에 observer > subject 로 전달되는 이벤트를 observer 에게 전달 Publish Subject > 이벤트가 전달 되는 즉시 구독자에게 전달하는 subject -> subject 가 최초로 생성되는 시점과
next 이벤트 방출 이후 completed 이벤트 전달하나의 항목을 방출하는 observable 생성parameter 로 전달한 요소를 그대로 방출함1개 방출2개 이상의 요소 방출원하는 수만큼 요소 방출 가능배열로 받은 요소를 하나씩 순서대로 방출정수를 지정된 수만큼
옵져버블이 방출하는 next 이벤트를 필터링, completed 와 error 이벤트만 구독자로 전달작업의 성공/실패에만 관심 있을 때 사용 특정 인덱스에 위치한 요소를 제한적으로 방출, 구독자에게 하나의 요소만 전달되고 나머지는 무시\--- 2 요소만 방출특정 요소를
옵져버블이 방출하는 모든 요소를 하나의 배열로 방출 (종료전까지 전달 x)subject .toArray() .subscribe { print$(0) } .disposed(by: disposeBag)subject.onNext(1) // 방출 Xsubject.on