RxSwift의 입문 공부 기록
✓ iOS 프로개발자이신 곰튀김님이 제공하는 RXSwift 4시간안에 끝내기 강의를 통해 RxSwift의 기본을 배우고 기록합니다.
* An API for asynchronous programming with observable streams
➣ 감시 스트림(Observable) 사용 비동기 프로그래밍을 위한 API
- MS에서 처음 만들었다.
- Observable : 제일 중요한 기능, 이것만 알면 다 쓸 수 있다.
- Operators : 이걸 쓰면 좀더 효율적으로 구현 가능
- Scheduler : 여러군데 활용이 가능
- Subject : 무언가 만들 수 있음
- Single : 가장 중요하지 않음
➣ RxMarble 사이트에서 실제 마블 동작 다이어그램을 확인 가능 : https://rxmarbles.com/
- DispatchQueue에는 크게 sync, async 두가지가 있음. 더 세부적으로 보자면..
총 네가지 분류를 해볼 수 있다.
* Async한 코드를 보다 간결하게 표현할 수 있는 방법이 바로 RxSwift이다.
* 비동기 구현내용이 간단할때는 RxSwift와 일반 코드의 차이를 느끼기 힘들다.
* 보다 복잡한 구현이 이루어질때 RxSwift가 진가를 발휘한다.
* 기존 iOS에서 제공하는 Promise kit vs RxSwift 둘다 구현은 가능하다. 하지만 간결함의 차이가 난다.
JUST() 출력결과: print가 바로 실행된다.
-> Hello World
FROM() 출력결과: 배열의 요소를 하나씩 하나씩 하나씩 차례대로 처리한다.
✓ 작업 완료 후에 completed 분기가 실행이 된다!
Single : 하나의 특정 동작만 처리 여러동작 잡히면 에러처리
✓ single()을 실행하기 위해선 작업이 한개만 들어와야 한다!
메인스레드를 사용하지 않고 UI처리를 하면 버벅임이 생길 수 있다. 메인스레드에서 동작시켜야 한다.
현재 메인스레드로 만 전부 진행하기 때문에 실행간 렉이 걸린다. 이때 사용할 수 있는 것이 Scheduler이다.
✭ 동시실행이 필요할 때 => 메인스레드 사용 전 동시성 실행 스케줄러 :
✭ 메인스레드 동작에 사용되는 스케쥴러 지정 : .observeOn(MainScheduler.instance)를 사용한다.
✓ subscribeOn은 어느 위치에 지정해도 문제없다. 사용하는것이 아닌 사용을 위해 등록만 하는 과정이기 때문이다.
✓ subscribeOn이후 subscribe가 생기면 그 순간 해당 subscribe는 가장 최근에 지정한 subscribeOn 스케쥴러 정책에 따라 실행된다.
- Subject의 종류 : Async Subject, BehaviorSubject, publishSubject, ReplaySubject
- 최초 SubScribe 이후, Default값으로 상태를 지켜보며 기다리다가 어떤 subscribe가 발생하면
➢ 그 Subscribe에 최근 데이터값을 넘겨준다.
- 해당 Subject가 종료 되면 이후 라는 스트림에서 Subscribe를 해도 해당 Subject는 종료된다.
✓ Bullet View만 상황을 지켜보다가 Enable or Disable 여부를 판단하여 변경할 수 있다.
* (value: false) -> default 값으로 false 설정을 했음을 의미
- 데이터가 생성될 때마다 해당 Subject를 Subscribe한 놈들에게 전부 해당 데이터를 전달한다.
- 마블 3개가 지나간 뒤 다른 Subscribe가 진행되면 해당 Stream에 이전 마블 3개를 전부 전달한다.
- 이후 생성되는 데이터는 동일하게 모든 Stream에 전달된다.
// MainScheduler 등 명시 안하고 메인스레드로 돌려서 UI 등 처리할 수 있는 또 다른 방법 정도로 이해해두면 됨
viewModel.idBulletVisible
.asDriver()
.drive(onNext: idValidView.isHidden = $0)
.disposed(by: disposeBag)
self.rx.viewWillDisappear.subscribe...
self.rx.viewWillAppear().take(1).subscribe...
// -> (viewWillAppear에 여러번 들러도 한번만 처리하게 하는 기능) 등의 접근 가능- ----
view.rx
.anyGesture(.top(), .swipe([up, .down]))
.when(.recognized)
.subscribe(onNext: { _ in
dismiss presented photo
})
.disposed(by: disposeBag)
* 이로 인한 메모리 누수 방지를 위해 할 수 있는 방법
1) 클로져 내 [weak self]를 고려해야 한다.
2) disposeBag = DisposeBag() 의 활용
여러분들은 RxSwift를 4시간만에 끝내기는 커녕 3시간만에 끝내셨습니다(?)
요즘 관심이 높은 RxSwift!
RxSwift는 Swift에 ReactiveX를 적용시켜 비동기 프로그래밍을 직관적으로 작성할 수 있도록 도와주는 라이브러리입니다.
즉, RxSwift는 도구입니다. 하지만 높은 러닝커브에 쉽게 접근하지 못하는 분이 많습니다.
도구를 이용하려고 배우고 노력하는 시간이 너무 큰 것은 배보다 배꼽이 더 큰 격입니다.
RxSwift의 근본적인 학습 자체보다는, 빠르게 사용법을 익혀 프로젝트에 적용하는 것이 현실주의 프로그래머들에게는 더 중요합니다.
- Blocking / Non-Blocking
- Sync / Async
- Thread, Concurrent, Parallel
- Concurrency Programming Guide
- pthread, Thread, Operation, OperationQueue, GCD
- Async Result 의 처리
- Closure Callback
- Delegate
- 나중에 Wrapper
- Observable
create - subscribe 로 데이터 사용
- Disposable 로 작업 취소
- stream의 life-cycle
- Subscribed
- Next
- Completed / Error
- Disposabled
- 간단한 생성 :
just,from - 필터링 :
filter,take - 데이터 변형 :
map,flatMap - 그 외 : A Decision Tree of Observable Operators
- Marble Diagram
- DispatchQueue
observeOn,subscribeOn
- Data Control
- Hot Observable / Cold Observable
- UI 작업의 특징
- Observable / Driver
- Subject / Relay
- RxViewController
- RxOptional
- RxExtension
- RxSwift Community Projects
- methodInvoked Example
- DelegateProxy example
- RxBlocking
- RxTest
- [Video] Testing an operator with TestScheduler - RxSwift
- [Video] Understanding RxSwift using RxTests — Yvette Cook
- [Article] Testing Your RxSwift Code
- [Official] ReactiveX
- [Video] RxSwift 4시간에 끝내기
- Unfinished Observable / Memory Leak
- (참조) 클로져와 메모리 해제 실험
- 카카오톡 RxSwift 오픈 채팅방
이 저작물은 크리에이티브 커먼즈 저작자표시 2.0 대한민국 라이선스에 따라 이용할 수 있습니다.
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent