blog_rxswift_03

1.swift

Observable<String>.just("test")
  .subscribe { event in
    switch event {
    case .next(let value):
      print(value)
    case .error(let error):
      print(error)
    case .completed:
      print("completed")
    }
  }

2.swift

Observable<Int>.interval(1, scheduler: MainScheduler.instance)
  .take(10)
  .subscribe(onNext: { value in
    print(value)
  }, onError: { error in
    print(error)
  }, onCompleted: {
    print("onCompleted")
  }, onDisposed: {
    print("onDisposed")
  })

3.swift

Observable<Int>.interval(1, scheduler: MainScheduler.instance)
  .take(10)
  .subscribe(onNext: { value in
    print(value)
  }, onError: { error in
    print(error)
  }, onCompleted: {
    print("onCompleted")
  }, onDisposed: {
    print("onDisposed")
  })

  DispatchQueue.main.asyncAfter(deadline: .now() + 3) {
    UIApplication.shared.keyWindow?.rootViewController = nil
  }

4.swift

let disposable = Observable<Int>.interval(1, scheduler: MainScheduler.instance)
  .take(10)
  .subscribe(onNext: { value in
    print(value)
  }, onError: { error in
    print(error)
  }, onCompleted: {
    print("onCompleted")
  }, onDisposed: {
    print("onDisposed")
  })

  DispatchQueue.main.asyncAfter(deadline: .now() + 3) {
    disposable.dispose()
  }

5.swift

import UIKit

import RxSwift

class CustomViewController: UIViewController {

  var disposeBag = DisposeBag()
  
  override func viewDidLoad() {
    super.viewDidLoad()
    
    test()
  }
  
  deinit {
    print(“deinit CustomViewController”)
  }

  func test() {
    Observable<Int>.interval(1, scheduler: MainScheduler.instance)
      .take(10)
      .subscribe(onNext: { value in
        print(value)
      }, onError: { error in
        print(error)
      }, onCompleted: {
        print(“onCompleted”)
      }, onDisposed: {
        print(“onDisposed”)
      })
      .disposed(by: disposeBag)
    
    DispatchQueue.main.asyncAfter(deadline: .now() + 3) {
      UIApplication.shared.keyWindow?.rootViewController = nil
    }
  }
}

6.swift

disposeBag = DisposeBag()