[Combine] Cancellable이란

element들을 방출하는 스트림을 다 사용했다면 cancel() 해줘야 자원이 dealloc 될 수 있는데요. 즉 이름 그대로 cancellation(취소)를 위한 프로토콜입니다. 

만약 cancel()을 호출하지 않으면 어떻게 될까요 ?

viewController의 deinit()이 호출되고 나도 스트림이 살아있기 때문에 값을 방출하게 됩니다. 

deinit {
    print("ViewController deinit")
}

let publisher = [1, 2, 3].publisher

publisher
    .map { $0 * 2 }
    .sink { value in
    print("\(value)")
}

//ViewController deinit
//2
//4
//6

 

스트림이 살아있다면 Timer, network access, disk I/O와 같은 사이드 이펙트가 발생할수 있다구 하네요.

그렇다면 이 문제를 어떻게 해결 할 수 있을까요 ?

값 발행 후 cancel()을 명시적으로 호출해주면 됩니다.

var cancellable: Cancellable?

deinit {
    print("ViewController deinit")
    cancellable.cancel()
}

let publisher = [1, 2, 3].publisher

cancellable = publisher
    .map { $0 * 2 }
    .sink { value in
    print("\(value)")
}

//ViewController deinit
//2
//4
//6

 

AnyCancellable은 클래스로 Cancellable 프로토콜을 채택하고 있습니다. 

 

sink로 값을 발행할때 리턴 타입이 AnyCancellable입니다.

public func sink(receiveValue: @escaping ((Self.Output) -> Void)) -> AnyCancellable

 

여러 스트림이 있을때 cancellable들을 바로 cancel() 하는것이 아니라 나중에 dealloc시 한번에 하고 cancel() 하고 싶을때

cancellable들을 담아줄 수 있는데요. store(in: Set<AnyCancellable>) 메소드를 사용합니다.

마치 RxSwift의 Disposbag()처럼 cancellable을 만들어둔뒤 Cancellable 인스턴스들을 담아줍니다.

let cancellable = Set<AnyCancellabe>()

deinit {
    print("ViewController deinit")
}

let publisher = [1, 2, 3].publisher

cancellable = publisher
    .map { $0 * 2 }
    .sink { value in
    print("\(value)")
}.store(in: self.cancellable)

//ViewController deinit
//2
//4
//6