clojure pipestream

io.clj

(let [in (java.io.PipedInputStream.)
      out (java.io.PipedOutputStream.)
      buf (java.io.BufferedWriter. (java.io.OutputStreamWriter. out))]

  (.connect out in)

  (doto buf
    (.write "abdf")
    (.write "abadfdf")
    (.flush))

  (with-open [w (clojure.java.io/writer "stuff.txt")]
    (loop [b (.read in)]
      (when (< 0 (.available in))
        (.write w b)
        (recur (.read in))))))