1 package org.apache.maven.scm.provider.accurev.cli;
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22 import java.io.IOException;
23
24 import org.apache.maven.scm.log.ScmLogger;
25 import org.codehaus.plexus.util.cli.StreamConsumer;
26
27
28
29
30 public class CommandOutputConsumer
31 implements StreamConsumer
32 {
33
34 private final ScmLogger logger;
35
36 private StreamConsumer decorated;
37
38 public CommandOutputConsumer( ScmLogger logger, StreamConsumer decorated )
39 {
40 this.decorated = decorated;
41 this.logger = logger;
42 }
43
44 public void consumeLine( String line ) throws IOException
45 {
46 if ( logger.isDebugEnabled() )
47 {
48 logger.debug( line );
49 }
50
51 if ( decorated != null )
52 {
53 decorated.consumeLine( line );
54 }
55 }
56
57 public void waitComplete()
58 {
59 if ( decorated instanceof XppStreamConsumer )
60 {
61 ( (XppStreamConsumer) decorated ).waitComplete();
62 }
63
64 }
65
66 }