RxSwiftRetainCount.swift

playgroundShouldContinueIndefinitely()

class Reactor {
  lazy var state: Observable<Int> = self.closure().concat(Observable<Int>.never())
  private lazy var closure: () -> Observable<Int> = self.closureImplementation()

  deinit {
    print("DEINIT SUCCESS!!!")
  }

  func closureImplementation() -> () -> Observable<Int> {
    return { [weak self] in
      guard let self = self else { return .empty() }
      print("B", _getRetainCount(self)) // 3

      return Observable<Int>.just(10)
        .flatMap { [weak self] _ -> Observable<Int> in
          guard let self = self else { return .empty() }
          print("C", _getRetainCount(self)) // 3
          return self.fooMutation()
        }
    }
  }

  func fooMutation() -> Observable<Int> {
    print("D", _getRetainCount(self))
    return Observable.just(20)
  }
}

example("Try yourself") {
  print("START")
  defer { print("END") }

  let disposeBag = DisposeBag()
  let reactor = Reactor()
  print("A", _getRetainCount(reactor)) // 2
  reactor.state.debug("state").subscribe().disposed(by: disposeBag)
}

@wplong11