|
|
@ -91,7 +91,9 @@ extension MessageSender {
|
|
|
|
let errors = results.compactMap { result -> Swift.Error? in
|
|
|
|
let errors = results.compactMap { result -> Swift.Error? in
|
|
|
|
if case .rejected(let error) = result { return error } else { return nil }
|
|
|
|
if case .rejected(let error) = result { return error } else { return nil }
|
|
|
|
}
|
|
|
|
}
|
|
|
|
if let error = errors.first { seal.reject(error) }
|
|
|
|
if let error = errors.first {
|
|
|
|
|
|
|
|
seal.reject(error)
|
|
|
|
|
|
|
|
} else {
|
|
|
|
Storage.write{ transaction in
|
|
|
|
Storage.write{ transaction in
|
|
|
|
sendNonDurably(message, in: thread, using: transaction).done {
|
|
|
|
sendNonDurably(message, in: thread, using: transaction).done {
|
|
|
|
seal.fulfill(())
|
|
|
|
seal.fulfill(())
|
|
|
@ -99,6 +101,7 @@ extension MessageSender {
|
|
|
|
seal.reject(error)
|
|
|
|
seal.reject(error)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
}
|
|
|
|
return promise
|
|
|
|
return promise
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|