You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@ant.apache.org by mb...@apache.org on 2007/06/27 23:07:21 UTC
svn commit: r551330 -
/ant/core/trunk/src/main/org/apache/tools/ant/taskdefs/StreamPumper.java
Author: mbenson
Date: Wed Jun 27 14:07:19 2007
New Revision: 551330
URL: http://svn.apache.org/viewvc?view=rev&rev=551330
Log:
fmting/javadoc
Modified:
ant/core/trunk/src/main/org/apache/tools/ant/taskdefs/StreamPumper.java
Modified: ant/core/trunk/src/main/org/apache/tools/ant/taskdefs/StreamPumper.java
URL: http://svn.apache.org/viewvc/ant/core/trunk/src/main/org/apache/tools/ant/taskdefs/StreamPumper.java?view=diff&rev=551330&r1=551329&r2=551330
==============================================================================
--- ant/core/trunk/src/main/org/apache/tools/ant/taskdefs/StreamPumper.java (original)
+++ ant/core/trunk/src/main/org/apache/tools/ant/taskdefs/StreamPumper.java Wed Jun 27 14:07:19 2007
@@ -15,7 +15,6 @@
* limitations under the License.
*
*/
-
package org.apache.tools.ant.taskdefs;
import java.io.IOException;
@@ -40,22 +39,21 @@
private boolean started = false;
/**
- * Create a new stream pumper.
+ * Create a new StreamPumper.
*
* @param is input stream to read data from
* @param os output stream to write data to.
* @param closeWhenExhausted if true, the output stream will be closed when
* the input is exhausted.
*/
- public StreamPumper(InputStream is, OutputStream os,
- boolean closeWhenExhausted) {
+ public StreamPumper(InputStream is, OutputStream os, boolean closeWhenExhausted) {
this.is = is;
this.os = os;
this.closeWhenExhausted = closeWhenExhausted;
}
/**
- * Create a new stream pumper.
+ * Create a new StreamPumper.
*
* @param is input stream to read data from
* @param os output stream to write data to.
@@ -124,12 +122,11 @@
}
/**
- * This method blocks until the stream pumper finishes.
+ * This method blocks until the StreamPumper finishes.
* @throws InterruptedException if interrupted.
* @see #isFinished()
*/
- public synchronized void waitFor()
- throws InterruptedException {
+ public synchronized void waitFor() throws InterruptedException {
while (!isFinished()) {
wait();
}
@@ -142,8 +139,7 @@
*/
public synchronized void setBufferSize(int bufferSize) {
if (started) {
- throw new IllegalStateException(
- "Cannot set buffer size on a running StreamPumper");
+ throw new IllegalStateException("Cannot set buffer size on a running StreamPumper");
}
this.bufferSize = bufferSize;
}
---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscribe@ant.apache.org
For additional commands, e-mail: dev-help@ant.apache.org