[Swift] Combine - Scheduler

Why ?

---

• 알고 사용하기 위해서 하나씩 정리해보고 맛보려고한다.
• Combine 핵심 프로토콜 중 Scheduler에 대해 알아보자!

Scheduler

---

• closure의 실행시기와 방법을 정의하는 프로토콜이다.
• 가능한 빨리 코드를 실행시킬 수도 있고, 특정 시간 이후에 코드를 실행시킬 수도 있다.
• Thread, DispatchQueue와 같은 요소를 제어할 수 있다.
• Scheduler를 지정하지 않더라도 Combine은 기본 Scheduler를 제공한다.

func defaultSchduler() {
    let subject = PassthroughSubject<Int, Never>()
    
    let _ = subject.sink(receiveValue: { _ in
        print(Thread.isMainThread)
    })
    
    subject.send(1)
}

defaultSchduler() // true

• 기본적으로 main thread에서 일어나니까 true를 출력한다.

func defaultSchduler() {
    let subject = PassthroughSubject<Int, Never>()
    
    let _ = subject.sink(receiveValue: { _ in
        print(Thread.isMainThread)
    })
    
    subject.send(1)
    
    DispatchQueue.global().async {
        subject.send(2)
    }
}

defaultSchduler()

/*
    true
    false
 */

receive(on: )

---

• receive(on: )은 publisher로 부터 element를 수신할 scheduler를 지정하는 역할을 한다.
• downstream에 영향을 준다.

func receivePractice() {
    let publisher = ["Harry"].publisher
    
    publisher
        .map { _ in print(Thread.isMainThread) }
        .receive(on: DispatchQueue.global())
        .map { _ in print(Thread.isMainThread) }
        .sink { print(Thread.isMainThread) }
}

receivePractice()

/*
 true
 false
 false
*/

• 처음에는 main thread였지만 receive(on: )을 사용하여 DispatchQueue.global()로 바꿔주니 false로 출력된다.

Reference

https://zeddios.tistory.com/972?category=842493 

Combine (3) - Scheduler