Instantly share code, notes, and snippets.

What would you like to do?
import RxSwift
import RxCocoa
- main: 同期処理
- serialBackground: 非同期処理
- concurrentBackground: 並列処理
struct RxScheduler {
static let sharedInstance = RxScheduler()
let main: SerialDispatchQueueScheduler
let serialBackground: SerialDispatchQueueScheduler
let concurrentBackground: ImmediateSchedulerType
init() {
main = MainScheduler.instance
serialBackground = SerialDispatchQueueScheduler(globalConcurrentQueueQOS: .Default)
let operationQueue = NSOperationQueue()
operationQueue.maxConcurrentOperationCount = 5
operationQueue.qualityOfService = NSQualityOfService.UserInitiated
concurrentBackground = OperationQueueScheduler(operationQueue: operationQueue)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment