が生成されたプロセス

Question

のInputStreamを監督私は、次のbashスクリプトを起動し、非同期的にその標準出力をキャプチャしようとしている：ここで

#!/bin/bash 

sleep 2; 
echo "one"; 
sleep 2; 
echo "two"; 
sleep 2; 
echo "three"; 
# ... possibly infinite.. 

は、Javaコードは、これまでのところです：

ProcessBuilder pb = new ProcessBuilder("sleeper"); 
Process process = pb.start(); 
InputStream input = process.getInputStream(); 

// now I continue in pseudo-code: 

supervise the input-stream. 
whenever a new line arrives: 
    check if the line equals "two"; 
     then: doSomeAction(); 

注：I実際にJavaでプログラムを書いているわけではありません。私はClojureに書いていますが、私はまだClojureのアプローチを見つけていません。だから私はClojureでラップされたJavaネイティブAPIを使用しようとしています。

---

nodejs例

カントーはもう少し私の意図を明確に、ここでは正確に行いNode.jsのためのJavaScriptコードは、私が欲しいものです：

const spawn = require('child_process').spawn; 
const sleeper = spawn('sleeper'); 

sleeper.stdout.on('data', (data) => { 
    if (data.toString() === "two\n") { 
     doSomeAction(); 
    } 
}); 

Answer 1

することができますclojure.java.ioのツールを簡単なJava相互運用機能とともに使用してください。

ここでは、始めるためにいくつかのコードです：

(require '[clojure.java.io :refer [reader]]) 

(let [process (.start (ProcessBuilder. ["./sleeper"]))] 
    (with-open [r (reader (.getInputStream process))] 
    (doseq [line (line-seq r)] 
     (when (= line "two") 
     (println line))))) 

があなたのREPLにこれを貼り付け、あなたは適切な遅延の後two出力されているが表示されるはずですが。