Add reproduce steps for race condition

GetStream · Sep 5, 2019 · f3f201a · f3f201a
1 parent 526444b
commit f3f201a
Show file tree

Hide file tree

Showing 2 changed files with 13 additions and 0 deletions.
diff --git a/Example/ChatExample/CustomChatViewController.swift b/Example/ChatExample/CustomChatViewController.swift
@@ -9,15 +9,27 @@
 import UIKit
 import StreamChatCore
 import StreamChat
+import RxSwift
+
+var disposeBag2 = DisposeBag()
 
 class CustomChatViewController: ChatViewController {
 
     required init?(coder aDecoder: NSCoder) {
         super.init(coder: aDecoder)
+        Client.shared.set(user: .user2, token: .token2)
         let channel = Channel(id: "general", name: "General")
         channelPresenter = ChannelPresenter(channel: channel)
     }
 
+    override func viewDidLoad() {
+        super.viewDidLoad()
+        disposeBag2 = DisposeBag()
+        Client.shared.onEvent(.messageNew).subscribe(onNext: { event in
+            print(event)
+        }).disposed(by: disposeBag2)
+    }
+
     override func messageCell(at indexPath: IndexPath, message: Message, readUsers: [User]) -> UITableViewCell {
         let cell = tableView.dequeueReusableCell(withIdentifier: "message")
             ?? UITableViewCell(style: .value2, reuseIdentifier: "message")

diff --git a/Sources/Core/Client/Client+Setup.swift b/Sources/Core/Client/Client+Setup.swift
@@ -172,6 +172,7 @@ extension Client {
             .do(onDispose: { [weak self] in self?.webSocket.disconnect() })
 
         return Observable.combineLatest(appState, internetIsAvailable, webSocketResponse)
+            .delay(.seconds(1), scheduler: MainScheduler.instance)
             .map { [weak self] in self?.webSocket.parseConnection(appState: $0, isInternetAvailable: $1, event: $2) }
             .unwrap()
             .distinctUntilChanged()