Use shared queue for postbox

This commit is contained in:
Peter 2019-06-27 01:12:02 +03:00
parent 99dc1729a0
commit 1ac4eb51e8

View File

@ -932,15 +932,17 @@ func debugRestoreState(basePath:String, name: String) {
} }
} }
private let sharedQueue = Queue(name: "org.telegram.postbox.Postbox")
public func openPostbox(basePath: String, seedConfiguration: SeedConfiguration, encryptionParameters: ValueBoxEncryptionParameters) -> Signal<PostboxResult, NoError> { public func openPostbox(basePath: String, seedConfiguration: SeedConfiguration, encryptionParameters: ValueBoxEncryptionParameters) -> Signal<PostboxResult, NoError> {
let queue = Queue(name: "org.telegram.postbox.Postbox") let queue = sharedQueue
return Signal { subscriber in return Signal { subscriber in
queue.async { queue.async {
let _ = try? FileManager.default.createDirectory(atPath: basePath, withIntermediateDirectories: true, attributes: nil) let _ = try? FileManager.default.createDirectory(atPath: basePath, withIntermediateDirectories: true, attributes: nil)
#if DEBUG #if DEBUG
//debugSaveState(basePath: basePath, name: "previous1") //debugSaveState(basePath: basePath, name: "previous1")
debugRestoreState(basePath: basePath, name: "previous1") //debugRestoreState(basePath: basePath, name: "previous1")
#endif #endif
let startTime = CFAbsoluteTimeGetCurrent() let startTime = CFAbsoluteTimeGetCurrent()