[RxSwift] Schedular란 (subscribeOn, observeOn)

이름은 조금 다르지만 어느 곳에서 작업 할지(main, global) 실행 흐름의 위치를 지정해주는 것을 말합니다.

기본 swift에서는 thread 작업을 비동기적으로 처리하기 위해 GCD를 사용했었습니다. RxSwift에서 GCD에 대응되는 개념이 Schedular라고 할 수 있습니다. 
Schedular를 통해 Observable을 어디서 생성할지, Observer가 어디서 관찰할지 지정해 줄 수 있습니다.

 

observeOn 과 subscribeOn은 스케줄러로 작동되는 대표적인 두 연산자입니다.

observeOn과 subscribeOn

둘의 차이를 명확하게 구분하는데 있어

http://rx-marin.com/post/observeon-vs-subscribeon/

observeOn vs. subscribeOn

이 글을 참고했습니다 (설명 짱 👍👍)

 

observeOn과 subscribeOn의 예제를 보기 전에 observable이 subscription 되는 흐름을 먼저 살펴봅시다.
아래 그림과 같이 3단락으로 구분 할 수 있습니다.

1. observable을 정의합니다. observable을 create로 생성할때 이것은 아직 생성되었음을 나타내지 않습니다. observable는 subscribe되었을 때 생성됩니다. 이곳에선 미래에 사용할 값들을 저장하고 있는 것입니다.
2. Map, filter과 같은 operator을 사용해 값을 방출합니다. 여전히 아무 작업도 실행되지 않습니다.
3. subscribe(…)를 호출할때 실행이 이루어집니다. 

여기엔 두가지 포인트가 있습니다. 
Observable.create {} 코드는 (subscription code) subscribe() 메소드로부터 호출됩니다.

이 함수는 subcription을 만들고 element를 생성하는 작업을 수행합니다.

subscribe()  코드는 (observation code) 방출된 값을 관찰하는 곳입니다. 

subscribeOn

Subscription code가 실행될 스케줄러를 바꾸는 메소드입니다. 

기본적으로 observable의 생성은 subscribe()를 호출한 스레드에서 불립니다. 

subscribeOn() 메서드는 observable을 생성할 스레드를 바꿀 수 있게 해줍니다.

 

Observable<Int>.create { observer in
    observer.onNext(1)
    sleep(1)
    observer.onNext(2)
    return Disposables.create()
}
.subscribeOn(ConcurrentDispatchQueueScheduler(qos: .background))
.subscribe(onNext: { el in
    print(Thread.isMainThread)
})

위 코드에서 subscribeOn이 쓰였습니다. subscribeOn의 역할에 대입해 본다면
observable()이 생성할 스케줄러를 바꿔주는데, concurrent schedular로 background에서 하도록 바꿔주고 있다는 뜻이겠죠 ?

 

[main] subscribe() -> [background] create{ … } -> [background] onNext { … }

의 실행 흐름을 가지며 false를 출력할 것입니다. 

만약 subscribe() 함수 내에서

.subscribe(onNext: { el in
	self.loginButton.isSelected = true
})

와 같은 UI 작업이 필요하다고 생각해봅시다.. 아니 그러면 당근 main 스레드에서 작동해야 하겠죠 ? 

 

.subscribeOn(ConcurrentDispatchQueueScheduler(qos: .background))

를 통해 작업의 흐름을 background로 바꿔줬었기 때문에 다시 main 스레드로 옮겨줘야 합니다. 이때 observeOn() 메서드를 사용 할 수 있습니다.

observeOn()

Observation code가 실행될 스케줄러를 바꾸는 메소드 입니다.

값을 방출할때 스케줄러를 변경할 필요가 있다면 보통 observeOn() 메서드를 사용하여 실행 흐름을 바꿔줍니다.

 

Observable<Int>.create { observer in
    observer.onNext(1)
    sleep(1)
    observer.onNext(2)
    return Disposables.create()
}
.observeOn(MainScheduler.instance)
.subscribeOn(ConcurrentDispatchQueueScheduler(qos: .background))
.subscribe(onNext: { el in
    print(Thread.isMainThread)
})

이렇게 된다면 observable을 생성할때는 background에서 onNext로 값을 방출할땐 main thread에서 사용 할 수 있게 됩니다.

 

[main] subscribe() -> [background] create{ ... } -> [main] onNext { ... }

 

subscribOn()은 사용해본적이 없어서 observable의 생성을 background에서 하는 경우에 대해 예제를 한번 살펴 봐야 할거 같아요 .. 그럼 이만 !! 

 

참고 : https://github.com/ReactiveX/RxSwift/blob/main/Documentation/Schedulers.md

GitHub - ReactiveX/RxSwift: Reactive Programming in Swift