1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
|
/* NEST (New Scala Test)
* Copyright 2007-2008 LAMP/EPFL
* @author Philipp Haller
*/
// $Id$
package scala.tools.partest.nest
import java.io.{Writer, PrintWriter, Reader, BufferedReader,
IOException, InputStream, StringWriter, InputStreamReader,
OutputStreamWriter, StringReader, OutputStream}
object StreamAppender {
def apply(reader: BufferedReader, writer: Writer) = {
val pwriter = new PrintWriter(writer, true)
new StreamAppender(reader, pwriter)
}
def apply(reader: Reader, writer: Writer) = {
val bufReader = new BufferedReader(reader)
val pwriter = new PrintWriter(writer, true)
new StreamAppender(bufReader, pwriter)
}
def appendToString(in1: InputStream, in2: InputStream): String = {
val swriter1 = new StringWriter
val swriter2 = new StringWriter
val reader1 = new BufferedReader(new InputStreamReader(in1))
val reader2 = new BufferedReader(new InputStreamReader(in2))
val app1 = StreamAppender(reader1, swriter1)
val app2 = StreamAppender(reader2, swriter2)
val async = new Thread(app2)
async.start()
app1.run()
async.join()
swriter1.toString + swriter2.toString
}
def inParallel(t1: Runnable, t2: Runnable, t3: Runnable) {
val thr1 = new Thread(t1)
val thr2 = new Thread(t2)
thr1.start()
thr2.start()
t3.run()
thr1.join()
thr2.join()
}
def inParallel(t1: Runnable, t2: Runnable) {
val thr = new Thread(t2)
thr.start()
t1.run()
thr.join()
}
def concat(in: InputStream, err: InputStream, out: OutputStream) = new Runnable {
override def run() {
val outWriter = new PrintWriter(new OutputStreamWriter(out), true)
val inApp = new StreamAppender(new BufferedReader(new InputStreamReader(in)),
outWriter)
val errStringWriter = new StringWriter
val errApp = StreamAppender(new BufferedReader(new InputStreamReader(err)),
errStringWriter)
inParallel(inApp, errApp)
// append error string to out
val errStrApp = new StreamAppender(new BufferedReader(new StringReader(errStringWriter.toString)),
outWriter)
errStrApp.run()
}
}
}
class StreamAppender(reader: BufferedReader, writer: PrintWriter) extends Runnable {
override def run() {
try {
var line = reader.readLine()
while (line != null) {
writer.println(line)
line = reader.readLine()
}
} catch {
case e: IOException =>
e.printStackTrace()
}
}
}
|
