Publishers.ReceiveOn

제네릭 구조체 | 특정 스케줄러에서 아래에 흐르는 Subscriber에게 요소를 전달하는 Publisher

이니셜라이저는 세 개의 인자를 요구한다.

• upstream : 상위에 흐르는 Publisher

• scheduler : 앞으로 체인이 동작할 스케줄러

• options : 스케줄러의 옵션

  • RunLoop의 경우 스케줄러 옵션을 지원하지 않는다.

  • DispatchQueue의 경우 DispatchQoS, DispatchWorkItemFlags, DispatchGroup 등을 정의하여 스케줄러 옵션을 지정할 수 있다.

이 코드를 작성한 후의 체인은 명시한 스케줄러에서 동작하게 된다.

Combine은 Scheduler 프로토콜을 정의하며, OperationQueue, DispatchQueue, RunLoop 등이 이 프로토콜을 채택한다.

receive 오퍼레이터와 관련이 있다.

// Publishers.ReceiveOn Publisher
Publishers.ReceiveOn(upstream: Just(Void()), scheduler: DispatchQueue.main, options: nil)
  .sink(receiveCompletion: { completion in
    switch completion {
    case .failure:
      print("Combine ReceiveOn Error")
    case .finished:
      print("Combine ReceiveOn Finish")
    }
  }, receiveValue: {
    print("Combine ReceiveOn")
  })
  .store(in: &cancellables)

// receive Operator
Just(Void())
  .receive(on: DispatchQueue.main)
  .sink(receiveCompletion: { completion in
    switch completion {
    case .failure:
      print("Combine ReceiveOn Error")
    case .finished:
      print("Combine ReceiveOn Finish")
    }
  }, receiveValue: {
    print("Combine ReceiveOn")
  })
  .store(in: &cancellables)

// Combine ReceiveOn
// Combine ReceiveOn Finish

DispatchQueue.main에서 동작하도록 스케줄러를 명시해 주었으므로 해당 코드가 명시된 이후의 동작은 메인 스레드에서 이루어지게 된다.

RxSwift

observeOn 오퍼레이터를 사용하여 구현할 수 있다.

Observable.just(Void())
  .observeOn(MainScheduler.instance)
  .subscribe(onNext: {
    print("RxSwift ReceiveOn")
  }, onError: { _ in
    print("RxSwift ReceiveOn Error")
  }, onCompleted: {
    print("RxSwift ReceiveOn Finish")
  })
  .disposed(by: disposeBag)

ReactiveSwift

observe 오퍼레이터를 사용하여 구현할 수 있다.

SignalProducer(value: Void())
  .observe(on: UIScheduler())
  .start { event in
    switch event {
    case .value:
      print("ReactiveSwift ReceiveOn")
    case .failed:
      print("ReactiveSwift ReceiveOn Error")
    case .completed:
      print("ReactiveSwift ReceiveOn Finish")
    default:
      break
    }
  }

참고

ReactiveX - Operators - ObserveOn