status-im
/
status-mobile
mirror of https://github.com/status-im/status-mobile.git
2
0
Fork 0
Code Issues Projects Releases Wiki Activity

Fix id->message-id

This commit is contained in:
janherich 2018-01-12 16:16:55 +01:00 committed by Oskar Thoren
parent 24d0b68c1f
commit 2f6742cdc7
No known key found for this signature in database
GPG Key ID: 5128AB0637CD85AF
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/status_im/utils/pre_receiver.cljs
View File

@ -24,16 +24,16 @@
mature-ch (async/chan) mature-ch (async/chan)
seen (atom #{})] seen (atom #{})]
(async/go-loop [] (async/go-loop []
(let [{:keys [id clock-value] :as msg} (async/<! in-ch)] (let [{:keys [message-id clock-value] :as msg} (async/<! in-ch)]
(swap! seen conj [clock-value id]) (swap! seen conj [clock-value message-id])
(async/<! (async/timeout delay-ms)) (async/<! (async/timeout delay-ms))
(async/put! mature-ch msg)) (async/put! mature-ch msg))
(recur)) (recur))
(async/go-loop [] (async/go-loop []
(let [{:keys [id clock-value] :as msg} (async/<! mature-ch)] (let [{:keys [message-id clock-value] :as msg} (async/<! mature-ch)]
(if reorder? (if reorder?
(if (earliest-clock-value-seen? @seen id clock-value) (if (earliest-clock-value-seen? @seen message-id clock-value)
(do (swap! seen disj [clock-value id]) (do (swap! seen disj [clock-value message-id])
(add-fn msg)) (add-fn msg))
(async/put! mature-ch msg)) (async/put! mature-ch msg))
(add-fn msg))) (add-fn msg)))