File tree Expand file tree Collapse file tree 1 file changed +4
-3
lines changed
Expand file tree Collapse file tree 1 file changed +4
-3
lines changed Original file line number Diff line number Diff line change 1313 [rethinkdb.query-builder :as qb]
1414 [rethinkdb.response :refer [parse-response]]
1515 [rethinkdb.types :as types])
16- (:import [java.io Closeable]))
16+ (:import [java.io Closeable]
17+ [clojure.lang Keyword]))
1718
1819(declare send-continue-query send-stop-query )
1920
5455 (s/stream->seq stream))
5556 java.lang.Iterable
5657 (iterator [this]
57- (.iterator (seq this)))
58+ (.iterator ^Iterable (seq this)))
5859 java.util.Collection
5960 (toArray [this]
6061 (into-array Object this))
162163 (qb/parse-query query-type term)
163164 (qb/parse-query query-type)))
164165 json (json/generate-string term {:key-fn #(subs (str %) 1 )})]
165- (when-not (and (= query-type :CONTINUE )
166+ (when-not (and (= ^Keyword query-type :CONTINUE )
166167 (not (get-in @conn [:pending token])))
167168 (s/put! client (io/encode query-protocol [token json])))
168169 (recur ))))))
You can’t perform that action at this time.
0 commit comments