Clear the cache for the stream handler once a listener sinks it

fluttercommunity · Dec 9, 2021 · a950049 · a950049
1 parent 42669de
commit a950049
Showing 1 changed file with 5 additions and 4 deletions.
diff --git a/ios/Classes/CachingStreamHandler.swift b/ios/Classes/CachingStreamHandler.swift
@@ -15,12 +15,12 @@ class CachingStreamHandler<T>: NSObject, FlutterStreamHandler {
     private let cacheSemaphore = DispatchSemaphore(value: 1)
 
     func add(_ taskId: String, _ value: T) {
-        cacheSemaphore.wait()
-        cache[taskId] = value
-        cacheSemaphore.signal()
-
         if let sink = eventSink {
             sink(value)
+        } else {
+            cacheSemaphore.wait()
+            cache[taskId] = value
+            cacheSemaphore.signal()
         }
     }
 
@@ -35,6 +35,7 @@ class CachingStreamHandler<T>: NSObject, FlutterStreamHandler {
         for cacheEntry in cache {
             events(cacheEntry.value)
         }
+        cache = [:]
         cacheSemaphore.signal()
 
         self.eventSink = events