fix: prefetch hangs when called concurrently

Author: duguyihou

example/ios/Podfile.lock

@@ -892,7 +892,7 @@ PODS:
     - React-debug
   - react-native-safe-area-context (4.9.0):
     - React-Core
-  - react-native-turbo-image (1.23.0):
+  - react-native-turbo-image (1.23.1):
     - APNGKit
     - Gifu
     - glog
@@ -1276,7 +1276,7 @@ SPEC CHECKSUMS:
   React-logger: 55764cd993880c6f887505854581c9faf68feff2
   React-Mapbuffer: 15dfcfeb4428d8799cce75e7fe85b18b706029e0
   react-native-safe-area-context: 435f4c13ac75ceed6135382ee77d57d1a5b5b2d6
-  react-native-turbo-image: 460a561a934738cc15a87dad8c0d1e3d76b90d5b
+  react-native-turbo-image: d484495eb22124812c83c8befbbecd762643ef47
   React-nativeconfig: b4d4e9901d4cabb57be63053fd2aa6086eb3c85f
   React-NativeModulesApple: 541d64309a3037060cc416db5c8a63ee5884048e
   React-perflogger: 5f49905de275bac07ac7ea7f575a70611fa988f2

ios/TurboImageViewManager.swift

@@ -3,7 +3,7 @@ import Nuke
 @objc(TurboImageViewManager)
 class TurboImageViewManager: RCTViewManager {
 
-  private var prefetcher: ImagePrefetcher?
+  private var prefetchers: [String: ImagePrefetcher] = [:]
 
   override func view() -> (TurboImageView) {
     return TurboImageView()
@@ -23,6 +23,7 @@ extension TurboImageViewManager {
                 with cachePolicy: String,
                 resolve: @escaping RCTPromiseResolveBlock,
                 reject: @escaping RCTPromiseRejectBlock) {
+    
     let imageRequests: [ImageRequest] = sources.map {
       guard let uri = $0["uri"] as? String,
             let url = URL(string: uri)
@@ -34,37 +35,22 @@ extension TurboImageViewManager {
       }
       return ImageRequest(urlRequest: urlRequest)
     }.compactMap{ $0 }
+    
+    let key = UUID().uuidString
+    var prefetcher: ImagePrefetcher?
     if(cachePolicy == "dataCache") {
       prefetcher = ImagePrefetcher(pipeline: ImagePipeline(configuration: .withDataCache))
     } else {
       prefetcher = ImagePrefetcher()
     }
+    prefetchers[key] = prefetcher
     prefetcher?.startPrefetching(with: imageRequests)
     prefetcher?.didComplete = {
       resolve(true)
+      self.prefetchers[key] = nil
     }
   }
 
-  @objc
-  func dispose(_ sources: [Source],
-               resolve: @escaping RCTPromiseResolveBlock,
-               reject: @escaping RCTPromiseRejectBlock) {
-    let imageRequests: [ImageRequest] = sources.map {
-      guard let uri = $0["uri"] as? String,
-            let url = URL(string: uri)
-      else { return nil }
-
-      var urlRequest = URLRequest(url: url)
-      if let headers = $0["headers"] as? [String: String] {
-        urlRequest.allHTTPHeaderFields = headers
-      }
-      return ImageRequest(urlRequest: urlRequest)
-    }.compactMap{ $0 }
-
-    prefetcher?.stopPrefetching(with: imageRequests)
-    resolve("Success")
-  }
-
   @objc
   func clearMemoryCache(_ resolve: @escaping RCTPromiseResolveBlock,
                         reject: @escaping RCTPromiseRejectBlock) {