Skip to content

Commit 40858a9

Browse files
committed
fix potential race condition in ReadableByteChannel -> seq-of bytes, mark 0.2.4-alpha1
1 parent 7db6dc5 commit 40858a9

File tree

2 files changed

+6
-8
lines changed

2 files changed

+6
-8
lines changed

project.clj

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,16 +1,16 @@
1-
(defproject byte-streams "0.2.3"
1+
(defproject byte-streams "0.2.4-alpha1"
22
:description "A simple way to handle the menagerie of Java byte represenations."
33
:license {:name "MIT License"
44
:url "http://opensource.org/licenses/MIT"}
5-
:dependencies [[primitive-math "0.1.5"]
5+
:dependencies [[primitive-math "0.1.6"]
66
[clj-tuple "0.2.2"]
7-
[manifold "0.1.6"]]
7+
[manifold "0.1.7-alpha5"]]
88
:profiles {:dev {:dependencies [[org.clojure/clojure "1.8.0"]
99
[org.clojure/test.check "0.9.0"]
1010
[codox-md "0.2.0" :exclusions [org.clojure/clojure]]]}}
1111
:test-selectors {:stress :stress
1212
:default (complement :stress)}
13-
:plugins [[lein-codox "0.9.4"]
13+
:plugins [[lein-codox "0.10.3"]
1414
[lein-jammin "0.1.1"]
1515
[ztellman/lein-cljfmt "0.1.10"]]
1616
:cljfmt {:indents {#".*" [[:inner 0]]}}

src/byte_streams.clj

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -695,10 +695,8 @@
695695
(let [^ByteBuffer buf (if direct?
696696
(ByteBuffer/allocateDirect n)
697697
(ByteBuffer/allocate n))]
698-
(while
699-
(and
700-
(.isOpen this)
701-
(pos? (.read this buf))))
698+
699+
(while (pos? (.read this buf)))
702700

703701
(when (pos? (.position buf))
704702
(.flip buf))))

0 commit comments

Comments
 (0)