Do not check .available when reading from input stream as it creates …

…race condition
clj-commons · Mar 15, 2018 · c66d8f1 · c66d8f1
1 parent 58b8366
commit c66d8f1
Showing 1 changed file with 3 additions and 4 deletions.
diff --git a/src/aleph/http/client_middleware.clj b/src/aleph/http/client_middleware.clj
@@ -75,10 +75,9 @@
   "Resolve and apply Transit's JSON/MessagePack decoding."
   [^InputStream in type & [opts]]
   {:pre [transit-enabled?]}
-  (when (pos? (.available in))
-    (let [reader (ns-resolve 'cognitect.transit 'reader)
-          read (ns-resolve 'cognitect.transit 'read)]
-      (read (reader in type (transit-read-opts opts))))))
+  (let [reader (ns-resolve 'cognitect.transit 'reader)
+        read (ns-resolve 'cognitect.transit 'read)]
+    (read (reader in type (transit-read-opts opts)))))
 
 (defn ^:dynamic transit-encode
   "Resolve and apply Transit's JSON/MessagePack encoding."