         (is (= (str "/" path)
               (-> result (deref 5000 "nil") read-string :path-info)))))))
 
-(let [serializer (java.util.concurrent.Executors/newSingleThreadExecutor)]
-  (defn mark [& msg]
-    (let [^Runnable r #(apply println
-                         (.format (java.text.SimpleDateFormat. "HH:mm:ss,SSS")
-                           (java.util.Date.)) msg)]
-      (.submit serializer r))))
-
-(deftest concurrent-ws-requests-should-not-cross-streams
+(marktest concurrent-ws-requests-should-not-cross-streams
   (replace-handler
     '(fn [request]
        (async/as-channel request

  (is (re-find #"this is not the first send"
        (read-string (get-body (str (cdef-url) "state"))))))

(deftest send!-to-ws-with-map-throws
  (replace-handler
    '(do
       (reset! client-state (promise))

               :on-error (fn [_ e]
                           (println "CHANNEL ERROR send!-a-file")
                           (.printStackTrace e)))))]
    (flog
      (replace-handler handler)
      (is (= (slurp (io/file (io/resource "public/foo.html")))
            (String. (get-body (cdef-url)))))
      (is (= :complete! (read-string (get-body (str (cdef-url) "state")))))

      (replace-handler handler)
      (let [result (promise)]
        (with-open [socket (ws/connect (cdef-url "ws")
                             :on-binary (fn [m _ _]
                                          (deliver result m)))]
          (is (= (into [] (-> (io/resource "public/foo.html")
                            io/file slurp .getBytes))
                (into [] (deref result 5000 nil))))))
      (is (= :complete! (read-string (get-body (str (cdef-url) "state"))))))))

(marktest send!-with-input-stream-larger-than-size-hint
  (let [handler
        '(do
           (reset! client-state (promise))
