don't try to decode chunks of a larger stream, fixes clj-commons/aleph#348, mark 0.2.4-alpha4

Author: ztellman

project.clj

@@ -1,4 +1,4 @@
-(defproject byte-streams "0.2.4-alpha3"
+(defproject byte-streams "0.2.4-alpha4"
   :description "A simple way to handle the menagerie of Java byte represenations."
   :license {:name "MIT License"
             :url "http://opensource.org/licenses/MIT"}
@@ -7,6 +7,7 @@
                  [manifold "0.1.7-alpha5"]]
   :profiles {:dev {:dependencies [[org.clojure/clojure "1.8.0"]
                                   [org.clojure/test.check "0.9.0"]
+                                  [rhizome "0.2.9"]
                                   [codox-md "0.2.0" :exclusions [org.clojure/clojure]]]}}
   :test-selectors {:stress :stress
                    :default (complement :stress)}

src/byte_streams/graph.clj

@@ -286,31 +286,32 @@
               result)))))))
 
 (defn seq-conversion-fn [g convert wrapper dst]
-  (let [path (->> g
-               possible-sources
-               (remove #(nil? (.wrapper ^Type %)))
-               (map #(conversion-path g % dst))
-               (remove nil?)
-               (sort-by :cost)
-               first)
+  (let [path      (->> g
+                    possible-sources
+                    (remove #(nil? (.wrapper ^Type %)))
+                    (remove #(#{String CharSequence} (.type ^Type %)))
+                    (map #(conversion-path g % dst))
+                    (remove nil?)
+                    (sort-by :cost)
+                    first)
         ^Type src (-> path :path first first)]
 
     (when src
       (let [wrapper' (.wrapper src)
-            type' (.type src)]
+            type'    (.type src)]
         (fn [x options]
           (->> x
 
             ((condp = [wrapper wrapper']
-               '[seq vector] vec
+               '[seq vector]    vec
                '[stream vector] (comp vec s/stream->seq)
-               '[seq stream] s/->source
-               '[stream seq] s/stream->seq
+               '[seq stream]    s/->source
+               '[stream seq]    s/stream->seq
                identity))
 
             ((condp = wrapper'
                'vector (partial mapv #(convert % type' options))
-               'seq (partial map #(convert % type' options))
+               'seq    (partial map #(convert % type' options))
                'stream (partial s/map #(convert % type' options))))
 
             (#((conversion-fn g src (-> path :path last last)) % options))))))))