commit dd03565e16a255311fece3608a8822945c7e91a4
author Andreas Traczyk <andreas.traczyk@savoirfairelinux.com> Thu Feb 22 20:40:04 2018 -0500
committer Kateryna Kostiuk <kateryna.kostiuk@savoirfairelinux.com> Fri Feb 23 13:44:34 2018 -0500
tree a75e71e56c64db4c437fb8e08919970320c69b76
parent 39fe4c836f592a531352cdca03fe3a20c06f7ed8

fix: add semaphore unlock on updateMessageStatus failure

Change-Id: I891ef9df9a711959962c7821c13198b0464af127
Reviewed-by: Kateryna Kostiuk <kateryna.kostiuk@savoirfairelinux.com>

Ring/Ring/Services/ConversationsService.swift

diff --git a/Ring/Ring/Services/ConversationsService.swift b/Ring/Ring/Services/ConversationsService.swift
index b134e95..b8a0959 100644
--- a/Ring/Ring/Services/ConversationsService.swift
+++ b/Ring/Ring/Services/ConversationsService.swift
@@ -299,12 +299,15 @@
                         event.addEventInput(.id, value: account.id)
                         event.addEventInput(.uri, value: uri)
                         self.responseStream.onNext(event)
-                    })
-                    .disposed(by: self.disposeBag)
+                    }) { _ in
+                        self.messagesSemaphore.signal()
+                    }.disposed(by: self.disposeBag)
             } else {
                 self.log.warning("messageStatusChanged: Message not found")
                 self.messagesSemaphore.signal()
             }
+        } else {
+            self.messagesSemaphore.signal()
         }
 
         log.debug("messageStatusChanged: \(status.rawValue) for: \(messageId) from: \(account.id) to: \(uri)")