ReactiveX/RxSwift
1
1
Fork 0
mirror of https://github.com/ReactiveX/RxSwift.git synced 2024-10-04 22:17:41 +03:00
Code Issues Projects Releases Wiki Activity

Fix linux

Browse Source
This commit is contained in:
freak4pc 2020-10-02 09:25:47 +03:00 committed by Shai Mishali
parent 28a9b8c7e2
commit f998d98120
1 changed files with 15 additions and 29 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

44
RxBlocking/RunLoopLock.swift
View File

@ -12,12 +12,7 @@ import RxSwift
#if os(Linux)
import Foundation
#if compiler(>=5.0)
let runLoopMode: RunLoop.Mode = .default
#else
let runLoopMode: RunLoopMode = .defaultRunLoopMode
#endif
let runLoopModeRaw: CFString = unsafeBitCast(runLoopMode.rawValue._bridgeToObjectiveC(), to: CFString.self)
#else
let runLoopMode: CFRunLoopMode = CFRunLoopMode.defaultMode
@ -67,32 +62,23 @@ final class RunLoopLock {
}
if let timeout = self.timeout {
#if os(Linux)
switch Int(CFRunLoopRunInMode(runLoopModeRaw, timeout, false)) {
case kCFRunLoopRunFinished:
return
case kCFRunLoopRunHandledSource:
return
case kCFRunLoopRunStopped:
return
case kCFRunLoopRunTimedOut:
throw RxError.timeout
default:
fatalError("This failed because `CFRunLoopRunResult` wasn't bridged to Swift.")
}
let runLoopResult = CFRunLoopRunInMode(runLoopModeRaw, timeout, false)
#else
switch CFRunLoopRunInMode(runLoopMode, timeout, false) {
case .finished:
return
case .handledSource:
return
case .stopped:
return
case .timedOut:
throw RxError.timeout
default:
return
}
let runLoopResult = CFRunLoopRunInMode(runLoopMode, timeout, false)
#endif
switch runLoopResult {
case .finished:
return
case .handledSource:
return
case .stopped:
return
case .timedOut:
throw RxError.timeout
default:
return
}
}
else {
CFRunLoopRun()