fix concurrent async (#8)

patrick-zippenfenig · Dec 8, 2023 · e7b1b81 · e7b1b81
1 parent f08b1a6
commit e7b1b81
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/Sources/ClickHouseVapor/Application+ClickHouseNIO.swift b/Sources/ClickHouseVapor/Application+ClickHouseNIO.swift
@@ -87,12 +87,13 @@ extension Application {
         }
 
         internal var pool: EventLoopGroupConnectionPool<ClickHouseConfiguration> {
+            let lock = self.application.locks.lock(for: PoolKey.self)
+            lock.lock()
+            defer { lock.unlock() }
+
             if let existing = self.application.storage[PoolKey.self] {
                 return existing
             } else {
-                let lock = self.application.locks.lock(for: PoolKey.self)
-                lock.lock()
-                defer { lock.unlock() }
                 guard let configuration = self.configuration else {
                     fatalError("ClickHouse not configured. Use app.clickHouse.configuration = ...")
                 }