Skip to content

Commit

Permalink
suppress reflections
Browse files Browse the repository at this point in the history
  • Loading branch information
Takahiro Hozumi committed Apr 26, 2012
1 parent 213bd00 commit 9922546
Show file tree
Hide file tree
Showing 2 changed files with 5 additions and 4 deletions.
3 changes: 2 additions & 1 deletion project.clj
Original file line number Original file line Diff line number Diff line change
@@ -1,4 +1,5 @@
(defproject org.clojars.hozumi/clj-commons-exec "1.0.4" (defproject org.clojars.hozumi/clj-commons-exec "1.0.4"
:description "Apache Commons Exec wrapper for Clojure" :description "Apache Commons Exec wrapper for Clojure"
:dependencies [[org.clojure/clojure "1.3.0"] :dependencies [[org.clojure/clojure "1.3.0"]
[org.apache.commons/commons-exec "1.1"]]) [org.apache.commons/commons-exec "1.1"]]
:warn-on-reflection true)
6 changes: 3 additions & 3 deletions src/clj_commons_exec.clj
Original file line number Original file line Diff line number Diff line change
Expand Up @@ -96,13 +96,13 @@
(let [pumper (if flush-input? (let [pumper (if flush-input?
(FlushStreamPumper. in os) (FlushStreamPumper. in os)
(StreamPumper. in os true)) (StreamPumper. in os true))
t (Thread. pumper)] t (Thread. ^Runnable pumper)]
(swap! threads conj t) (swap! threads conj t)
(.setDaemon t true)) (.setDaemon t true))
(try (.close os) (try (.close os)
(catch IOException e)))) (catch IOException e))))
(start [_] (start [_]
(doseq [t @threads] (.start t))) (doseq [^Thread t @threads] (.start t)))
(stop [_] (stop [_]
(doseq [^Thread t @threads] (doseq [^Thread t @threads]
(try (.join t) (try (.join t)
Expand Down Expand Up @@ -159,7 +159,7 @@
(if (string? in) (string->input-stream in (:encode opts)) in)) (if (string? in) (string->input-stream in (:encode opts)) in))
num-cmds-1 (-> cmds-list count dec) num-cmds-1 (-> cmds-list count dec)
pouts (repeatedly num-cmds-1 #(PipedOutputStream.)) pouts (repeatedly num-cmds-1 #(PipedOutputStream.))
pins (map (fn [pos] (PipedInputStream. pos)) pouts) pins (map (fn [^PipedOutputStream pos] (PipedInputStream. pos)) pouts)
outs (concat pouts [(:out opts)]) outs (concat pouts [(:out opts)])
errs (concat (repeat num-cmds-1 nil) [(:err opts)]) errs (concat (repeat num-cmds-1 nil) [(:err opts)])
ins (cons first-in pins) ins (cons first-in pins)
Expand Down

0 comments on commit 9922546

Please sign in to comment.