File tree Expand file tree Collapse file tree 1 file changed +3
-5
lines changed
Clojure-Websockets/src/clj/birdwatch Expand file tree Collapse file tree 1 file changed +3
-5
lines changed Original file line number Diff line number Diff line change 91
91
(do
92
92
(log/info " Received query:" params)
93
93
(let [res (query params)]
94
- ; (doseq [t res]
95
- ; (chsk-send! (:uid params) [:some/tweet (:_source t)]))
96
- (chsk-send! (:uid params) [:tweet/prev-chunk res])))
94
+ ; (doseq [t res] (chsk-send! (:uid params) [:some/tweet (:_source t)]))
95
+ (chsk-send! (:uid params) [:tweet/prev-chunk res])))
97
96
98
97
:else
99
98
(do (log/info " Unmatched event:" ev)
182
181
(go
183
182
(while true
184
183
(let [t (<! tweets-chan)]
185
-
186
184
(let [response (perc/percolate conn " percolator" " tweet" :doc t)
187
- matches (vec (map #(:_id %1 ) (esrsp/matches-from response)))]
185
+ matches (into #{} (map #(:_id %1 ) (esrsp/matches-from response)))]
188
186
(log/info " esrsp/matches-from" matches))
189
187
190
188
(doseq [uid (:any @connected-uids)]
You can’t perform that action at this time.
0 commit comments