ScheduledDisposable-example.swift

let queue = DispatchQueue.global()
let scheduler = ConcurrentDispatchQueueScheduler(queue: queue)

let observable = Observable<Void>.create { observer in
    observer.onCompleted()
    return ScheduledDisposable(scheduler: scheduler, disposable: Disposables.create {
        print("thread - \(Thread.current)")
    })
}

observable.subscribe()

// log:
// thread - <NSThread: 0x7f9631d62e60>{number = 3, name = (null)}