1 package org.apache.maven.surefire.junitcore;
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22 import java.util.ArrayList;
23 import java.util.List;
24 import org.apache.maven.surefire.report.ConsoleOutputReceiver;
25 import org.apache.maven.surefire.util.internal.ByteBuffer;
26
27
28
29
30 public class LogicalStream
31 {
32 private final List<Entry> output = new ArrayList<Entry>();
33
34 class Entry
35 {
36 final boolean stdout;
37
38 final byte[] b;
39
40 final int off;
41
42 final int len;
43
44 Entry( boolean stdout, byte[] b, int off, int len )
45 {
46 this.stdout = stdout;
47 this.b = ByteBuffer.copy( b, off, len );
48 this.off = 0;
49 this.len = len;
50 }
51
52
53 public void writeDetails( ConsoleOutputReceiver outputReceiver )
54 {
55 outputReceiver.writeTestOutput( b, off, len, stdout );
56 }
57
58 @Override
59 public String toString()
60 {
61 return new String( b, off, len );
62 }
63
64 public boolean isBlankLine()
65 {
66 return "\n".equals( toString() );
67 }
68 }
69
70 public synchronized void write( boolean stdout, byte b[], int off, int len )
71 {
72 Entry entry = new Entry( stdout, b, off, len );
73 if ( !entry.isBlankLine() )
74 {
75 output.add( entry );
76 }
77 }
78
79 public void writeDetails( ConsoleOutputReceiver outputReceiver )
80 {
81 for ( Entry entry : output )
82 {
83 entry.writeDetails( outputReceiver );
84 }
85 }
86
87
88 }