Fix RxSwift synchronization warning on bootstrap (#295)

Co-Epi · Jun 30, 2020 · c73ac28 · c73ac28
1 parent 2c22c36
commit c73ac28
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/CoEpi/common/log/CachingLog.swift b/CoEpi/common/log/CachingLog.swift
@@ -28,6 +28,8 @@ class CachingLog: LogNonVariadicTags {
     private let addLogTrigger: PublishSubject<LogMessage> = PublishSubject()
     private let disposeBag = DisposeBag()
 
+    private let loggerSerialQueue = DispatchQueue(label: "org.coepi.logger")
+
     init() {
         addLogTrigger.withLatestFrom(logs, resultSelector: {(message, logs) in
             (message, logs)
@@ -62,7 +64,9 @@ class CachingLog: LogNonVariadicTags {
     }
 
     private func log(_ message: LogMessage) {
-        addLogTrigger.onNext(message)
+        loggerSerialQueue.async { [weak self] in
+            self?.addLogTrigger.onNext(message)
+        }
     }
 
     private func addTag(tags: [LogTag], message: String) -> String {