Combine 개념 익히기

구글링 한 거 읽어보기!

Publisher

protocol Publisher {
	associatedtype Output
    associatedtype Failure: Error
    
    func subscribe<S: Subscriber>(_ subscriber: S)
    	where S.Input == Output, S.Failure == Failure
}

• 데이터 배출하는 친구
  • 구체적인 Output 및 실패 타입을 정의함
  • Subscriber 가 요청한 것 만큼 데이터를 제공
• 빌트인 Publisher인 Just, Future가 있음
  • Just는 값을 다루고
  • Future는 Function을 다룸
• iOS에서는 자동으로 제공해주는 녀석들이 있음
  • NotificationCenter
  • Timer
  • URLSession.dataTask

Subscriber

protocol Subscriber {
	associatedtype Input
    associatedtype Failure: Error
    
    func receive(subscription: Subscription)
    func receive(_ input: Input) -> Subscribers.Demand
    func receive(completion: Subscribers.Completion<Failure>)
}

• Publisher 에게 데이터 요청함
• Input, Failure 타입이 정의 필요함
• Publisher 구독후, 갯수를 요청함
• 파이프라인을 취소할 수 있음
• 빌트인 Subscriber인 assign과 sink가 있음
  • assign은 Publisher가 제공한 데이터를 특정 객체의 키패스에 할당
  • sink는 Publisher가 제공한 데이터를 받을 수 있는 클로져를 제공함

Subscriber & Publisher Pattern

Subscriber is attached to Publisher
Publisher sends a Subscription
Subscriber requests N values
Publisher sends N values or less
Publisher sends completion

Subscription

• Subscriber 와 Publisher가 연결됨을 나타내는 녀석
  • 쉽게 생각하면, Publisher 가 발행한 구독 티켓
  • 이 구독 티켓만 있으면, 데이터를 받을 수 있음
  • 이 구독 티켓이 사라지면 구독 관계도 사라짐
• Cancellable protocol을 따르고 있음
  • 따라서, Subscription을 통해 연결을 Cancel 할 수 있음

Subject (Publisher)

• send(_:) 메소드를 이용해서 이벤트 값을 주입시킬 수 있는 퍼블리셔
• 기존의 비동기 처리 방식에서 Combine으로 전환 시 유용함
• 2가지 빌트인 타입이 있음
  • PassthroughSubject
    • Subscriber 가 달라고 요청하면,
    • 그때부터, 받은 값을 전달해주기만 함
    • 전달한 값을 들고 있지 않음
  • CurrentValueSubject
    • Subscriber 가 달라고 요청하면,
    • 최근에 가지고 있던 값을 전달하고, 그때부터 받은 값을 전달함
    • 전달한 값을 들고 있음

@Published (Publisher)

• @Published 로 선언된 프로퍼티를 퍼블리셔로 만들어줌
• 클래스에 한해서 사용됨 (구조체에서 사용안됨)
• $를 이용해서 퍼블리셔에 접근할 수 있음

class Weather {
	@Published var temperature: Double
    init(temperature: Double) {
    	self.temperature = temperature
    }
}

let weather = Weather(temperature: 20)
let subscription = weather.$temperature.sink {
	print("Temperature now: \($0)")
}
weather.temperature = 25

Operator

• Publisher에게 받은 값을 가공해서 Subscriber에게 제공
• Input, Output, Failure type을 받는데 타입이 다를 수 있음
• 빌트인 오퍼레이터가 많이 있음
  • map, filter, reduce, collect, combineLatest...

Scheduler

• Scheduler는 언제, 어떻게 클로져를 실행할 지 정해주는 녀석임
• Operator에서 Scheduler를 파라미터로 받을 때가 있음
  • 따라서, 작업에 따라 백그라운드 혹은 메인스레드에서 작업이 실행될 수 있게 도와줌
• Scheduler가 스레드 자체는 아님

2가지 Scheduler 메소드

subscribe(on:)을 이용해서, publisher가 어느 스레드에서 수행할지 결정해주는 것

• 무거운 작업은 메인스레드가 아닌 다른 스레드에서 작업할 수 있게 도와줌
  • 예) 백그라운드 계산이 많이 필요한 것
  • 예) 파일 다운로드해야 하는 경우
    receive(on:)을 이용해서 operator, subscriber가 어느 스레드에서 수행할 지 결정해주는 것
• UI 업데이트 필요한 데이터를 메인스레드에서 받을 수 있게 도와줌
  • 예) 서버에서 가져온 데이터를 UI 업데이트 할 때

Pattern

일반적인 패턴

let jsonPublisher = MyJSONLoaderPublisher() // some publisher

jsonPublisher
	.subscribe(on: backgroundQueue)
    .receive(on: RunLoop.main)
    .sink { value in
    label.text = value

UI업데이트 시

🔴이렇게 하지말고

pub.sink {
	DispatchQueue.main.async {
    	//Do update ui
    }
}

🟢이렇게 하기

pub.receive(on: DispatchQueue.main).sink {
	// Do update ui
}