Skip to content

Commit 58b26ff

Browse files
committed
Simplify async-testing code
1 parent 547d273 commit 58b26ff

File tree

1 file changed

+1
-4
lines changed

1 file changed

+1
-4
lines changed

src/rethinkdb/net.clj

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -192,10 +192,7 @@
192192
(async/>! (:query-chan @conn) [token (qb/parse-query :CONTINUE)])))
193193

194194
(defn send-start-query [conn query & [opts]]
195-
(let [async? (->> [opts @conn]
196-
(remove nil?)
197-
(map :async?)
198-
first)]
195+
(let [async? (some :async? [opts @conn])]
199196
(send-first-query conn (qb/parse-query :START query) async?)))
200197

201198
(defn send-server-query [conn]

0 commit comments

Comments
 (0)