Merge pull request #370 from kachayev/fix-transit-reader-pushback

Do not check .available when reading from input stream to avoid race condition
clj-commons · Apr 3, 2018 · bbedd0d · bbedd0d
2 parents 63ef527 + c66d8f1
commit bbedd0d
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
@@ -74,10 +74,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."