File tree Expand file tree Collapse file tree 2 files changed +2
-2
lines changed
Clojure-Websockets/src/clj/birdwatch Expand file tree Collapse file tree 2 files changed +2
-2
lines changed Original file line number Diff line number Diff line change 25
25
" loop for finding percolation matches and delivering those on the appropriate socket"
26
26
(go-loop [] (let [t (<! percolation-chan)
27
27
response (perc/percolate conn " percolator" " tweet" :doc t)
28
- matches (into #{} (map #( :_id % 1 ) (esrsp/matches-from response)))] ; ; set with SHAs
28
+ matches (set (map :_id (esrsp/matches-from response)))] ; ; set with SHAs
29
29
(put! percolation-matches-chan [t matches @subscriptions]) ; ; send deref'd subscriptions as val
30
30
(recur ))))
Original file line number Diff line number Diff line change 22
22
(fn [step]
23
23
(let [cnt (volatile! 0 )]
24
24
(fn [r x]
25
- (when (== (mod @cnt 1000 ) 0 ) (log/info " processed" @cnt " since startup" ))
25
+ (when (zero? (mod @cnt 1000 )) (log/info " processed" @cnt " since startup" ))
26
26
(vswap! cnt inc)
27
27
(reset! last-received (t/now ))
28
28
(step r x)))))
You can’t perform that action at this time.
0 commit comments