From e95b4e10d2cc0b1761e3567d90586fabc3f4d8d7 Mon Sep 17 00:00:00 2001 From: Khoa Pham Date: Fri, 15 Sep 2017 15:05:26 +0200 Subject: [PATCH] Allow queue to be passed --- Source/Shared/Storage/AsyncStorage.swift | 5 +++-- Source/Shared/Storage/SyncStorage.swift | 5 +++-- 2 files changed, 6 insertions(+), 4 deletions(-) diff --git a/Source/Shared/Storage/AsyncStorage.swift b/Source/Shared/Storage/AsyncStorage.swift index 51dcbc1..f2cb7f1 100644 --- a/Source/Shared/Storage/AsyncStorage.swift +++ b/Source/Shared/Storage/AsyncStorage.swift @@ -4,10 +4,11 @@ import Foundation /// The completion closure will be called when operation completes. public class AsyncStorage { let internalStorage: StorageAware - public let serialQueue = DispatchQueue(label: "Cache.AsyncStorage.Queue") + public let serialQueue: DispatchQueue - init(storage: StorageAware) { + init(storage: StorageAware, serialQueue: DispatchQueue) { self.internalStorage = storage + self.serialQueue = serialQueue } } diff --git a/Source/Shared/Storage/SyncStorage.swift b/Source/Shared/Storage/SyncStorage.swift index 4909377..b87ae6b 100644 --- a/Source/Shared/Storage/SyncStorage.swift +++ b/Source/Shared/Storage/SyncStorage.swift @@ -4,10 +4,11 @@ import Foundation /// Block the current queue until the operation completes. public class SyncStorage { let internalStorage: StorageAware - fileprivate let serialQueue = DispatchQueue(label: "Cache.SyncStorage.Queue") + fileprivate let serialQueue: DispatchQueue - init(storage: StorageAware) { + init(storage: StorageAware, serialQueue: DispatchQueue) { self.internalStorage = storage + self.serialQueue = serialQueue } }