1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
|
(ns nrepl.response-test
(:require
[clojure.test :refer :all]
[nrepl.core :as nrepl]
[nrepl.transport :as t])
(:import
(java.util.concurrent BlockingQueue LinkedBlockingQueue TimeUnit)))
(deftest response-seq
(let [[local remote] (t/piped-transports)]
(doseq [x (range 10)] (t/send remote x))
(is (= (range 10) (nrepl/response-seq local 0)))
;; ensure timeouts don't capture later responses
(nrepl/response-seq local 100)
(doseq [x (range 10)] (t/send remote x))
(is (= (range 10) (nrepl/response-seq local 0)))))
(deftest client
(let [[local remote] (t/piped-transports)]
(doseq [x (range 10)] (t/send remote x))
(is (= (range 10) ((nrepl/client local 100) 17)))
(is (= 17 (t/recv remote)))))
(deftest client-heads
(let [[local remote] (t/piped-transports)
client1 (nrepl/client local Long/MAX_VALUE)
all-seq (client1)]
(doseq [x (range 10)] (t/send remote x))
(is (= [0 1 2] (take 3 all-seq)))
(is (= (range 3 7) (take 4 (client1 :a))))
(is (= :a (t/recv remote)))
(is (= (range 10) (take 10 all-seq)))))
|
