Disposable object that can be used to unsubscribe the observers.

RxSwift 주석 인용

리소스 정리에 사용되는 객체이다.

• 원래 completed 나 error 이벤트가 발생하면 알아서 정리되지만, 공식문서에서는 직접 리소스를 정리할 것을 추천하고 있다.
• 이 객체의 인스턴스 dispose() 를 호출하면 자원이 해제된다.
  • 공식문서에서는 이 방법 대신 DisposeBag 을 사용할 것을 추천하고 있다.

let fruits = ["🍎"," 🍇", "🍌"]

let subscription = Observable.from(fruits)
  .subscribe {
    print($0)
}

subscription.dispose()

dispose 를 호출하는 순간 자원이 정리되고, completed 이벤트 이전에 호출되었다면 completed 이벤트는 구독자에게 전달되지 않는다.

실행 취소에 사용하기

1초마다 1씩 증가한 정수를 방출하는 옵저버블이다. (0... 1... 2... 3... )

3초뒤에 dispose() 를 호출하여 자원을 정리한다.

• completed 이벤트 발생 전에 호출되었으므로 구독자에게 completed 는 전달되지 않는다.
• 따라서 대신 waitUntil 과 같은 연산자를 사용한다.

/// 실행 취소에 사용하는 예
let subscription2 = Observable<Int>.interval(.seconds(1), scheduler: MainScheduler.instance).subscribe { elem in
  print("Next", elem)
} onError: { error in
  print("Error", error)
} onCompleted: {
  print("Completed")
} onDisposed: {
  print("Disposed")
}

DispatchQueue.main.asyncAfter(deadline: .now() + 3) {
  /// 호출하는 즉시 모든 리소스가 해제된다.
  /// 그래서 next 다음에 completed 이벤트가 전달되지 않는다.
  subscription2.dispose()
}

결과값

Next 0

Next 1

Next 2

Disposed

DisposeBag 사용하기

Disposable 을 DisposeBag 에 넣는 방식으로 자원을 관리한다.