Merge pull request #57 from ikedam/feature/StdinShouldBlock

stdin should block and wait for new inputs till stdin is closed.
elastic · May 9, 2016 · 6015950 · 6015950
2 parents 466798d + 2037aa1
commit 6015950
Showing 1 changed file with 4 additions and 6 deletions.
diff --git a/src/stream2es/stream/stdin.clj b/src/stream2es/stream/stdin.clj
@@ -34,12 +34,10 @@
   (make-runner [_ opts handler]
     (StdinStreamRunner.
      (fn []
-       (loop [in (io/reader *in*)]
-         (if-not (.ready *in*)
-           (handler :eof)
-           (do
-             (handler (.readLine *in*))
-             (recur in)))))))
+       (do
+         (doseq [line (line-seq (io/reader *in*))] 
+           (handler line))
+         (handler :eof)))))
   StreamStorage
   (settings [_ opts]
     {:index.number_of_shards 2