[RxSwift] Disposable과 DisposeBag

안녕하세요 Foma 입니다.

 

오늘은 RxSwift에서 가장 기초가되는 Disposable과 DisposeBag에 대해서 알아보겠습니다.

 

바로 시작할게요~

 

Disposable

---

먼저 dispose의 사전적 의미는 뭘까요?

 

여러가지 의미가 있지만 Rx에서 사용되는 의미는 "처리하다" 라는 뜻이에요. ("취소하다" 라고 보셔도 될거같아요)

 

그렇다면 disposable은 "처리할수있는" 이겠죠?

 

만약 어떤 작업이 실행되는데 이게 너무 오래걸리거나 아니면 중간에 취소하고 싶다면 비동기 처리중인 작업을

 

멈춰야하겠죠? 

 

만약 Rx를 사용하지 않고 GCD로 비동기작업을 구현했다면 중간에 취소하는 것은 불가능하고

 

만약 취소해야한다면 OperationQueue를 사용해서 cancel해줘야 할거에요.

 

Rx는 cancel 대신 disposable을 사용해서 작업을 취소할 수 있습니다.

 

예제와 함께 보실게요.

 

예제를 설명드리면 0부터 10000000 카운트하는데 걸리는 시간을 구하는 것입니다.

 

아래와 같이 1부터 10000000까지 카운트가 완료되면 타이머가 멈추고 Completed를 띄워주는 것입니다.

여기에 stop버튼을 누르면 비동기작업을 멈추게 하는 것을 구현하고 싶으면 dispose를 이용하면 됩니다.

 

우선은 disposable 변수를 만들어주시고

 

위의 isCompletedCount 함수에 변수를 disposable로 정해주시고

stop액션에 정해준 disposable을 dispose해주시면 멈추는 기능 구현할 수 있습니다.

아래와 같이 stop버튼을 누르면 비동기 작업이 멈추게 되고 취소되었습니다로 레이블을 띄울 수 있습니다.

 

 

DisposeBag

---

만약 0부터 10000까지 세는 작업과 0부터 20000까지 세는 작업 등 여러가지 비동기 작업이 있고 

 

이 여러개의 비동기 작업을 한번에 취소하려고 할때는 어떻게 해야할까요?

 

바로 이때 처리를 담는 가방을 만들어놓고 이 가방을 한번에 지워버리면 됩니다.

 

이때 처리가 바로 disposable 이고 담는 가방이 DisposeBag 이죠.

 

사용방법은 disposeBag을 만들어줍니다.

그리곤 옵저버블을 반환하는 함수끝에 dispose를 달아주고 disposeBag에 담아줍니다.

그리고 이렇게 담긴 disposeBag을 비워주면 dispose가 달린 함수들은 모두 취소가 됩니다.

바로 아래처럼 한번에 두 비동기 작업이 취소가 됩니다.

Source Code

---

 

fomagran/RxSwift-Example

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62

import UIKit import RxSwift   class ViewController: UIViewController {          @IBOutlet weak var completed: UILabel!     @IBOutlet weak var number: UILabel!          var count = 0.0          var timer:Timer?     var disposable:Disposable?       override func viewDidLoad() {         super.viewDidLoad()         startTimer()         isCompletedCount()     }          func startTimer() {         timer = Timer.scheduledTimer(timeInterval: 0.1, target: self, selector: #selector(update), userInfo: nil, repeats: true)     }          @objc func update() {         count += 0.1         number.text = String(format: "%.1f",  count) + String("초가 걸렸어요")     }          @IBAction func stop(_ sender: Any) {         disposable?.dispose()         timer?.invalidate()         completed.text = "취소되었습니다."     }          func isCompletedCount() {         disposable = rxCountNumber()             .observeOn(MainScheduler.instance)             .subscribe({[weak self] _ in                 self?.completed.text = "Completed!"             })     }          func countNumber(completed: @escaping (Bool?) -> Void) {         DispatchQueue.global().async {             for _ in 0...10000000 {                          }             self.timer?.invalidate()             completed(true)         }     }          func rxCountNumber() -> Observable<Bool> {         return Observable.create { [weak self] o in             self?.countNumber { (result) in                 o.onNext(result ?? false)                 o.onCompleted()             }             return Disposables.create()         }     } } Colored by Color Scripter

cs

 

Reference

---

아래를 참고하였습니다.

iamchiwon/RxSwift_In_4_Hours