gered/clj-browserchannel
Archived
1
0
Fork 0
Code Issues Pull requests Packages Projects Releases Wiki Activity

minor cleanups

Browse source
This commit is contained in:
Gered 2016-05-11 15:45:58 -04:00
parent 548ff7825d
commit 89ad55b9c8
1 changed files with 5 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
clj-browserchannel/src/net/thegeez/browserchannel/server.clj
View file

@ -290,6 +290,7 @@
(= string noop-string)) (= string noop-string))
to-flush)) to-flush))
clojure.lang.PersistentQueue/EMPTY)])) clojure.lang.PersistentQueue/EMPTY)]))
(last-acknowledged-id [this] (last-acknowledged-id [this]
last-acknowledged-id) last-acknowledged-id)
@ -317,7 +318,7 @@
;; messages sent from server to client are arrays ;; messages sent from server to client are arrays
;; the client acknowledges received arrays when creating a new backwardchannel ;; the client acknowledges received arrays when creating a new backwardchannel
(acknowledge-arrays [this array-id]) (acknowledge-arrays [this array-id-str])
(queue-string [this json-string]) (queue-string [this json-string])
@ -454,8 +455,8 @@
(queue-string [this json-string] (queue-string [this json-string]
(update-in this [:array-buffer] queue json-string)) (update-in this [:array-buffer] queue json-string))
(acknowledge-arrays [this array-id] (acknowledge-arrays [this array-id-str]
(let [array-id (Long/parseLong array-id)] (let [array-id (Long/parseLong array-id-str)]
(update-in this [:array-buffer] acknowledge-id array-id))) (update-in this [:array-buffer] acknowledge-id array-id)))
;; tries to do the actual writing to the client ;; tries to do the actual writing to the client
@ -470,7 +471,7 @@
;; buffer contains [[1 json-str] ...] can't use ;; buffer contains [[1 json-str] ...] can't use
;; json-str which will double escape the json ;; json-str which will double escape the json
(doseq [p to-flush #_(next to-flush)] (doseq [p to-flush]
(write (:respond back-channel) (str "[" (to-pair p) "]"))) (write (:respond back-channel) (str "[" (to-pair p) "]")))
;; size is an approximation ;; size is an approximation