FileDocCategorySizeDatePackage
ConsumerPipe.javaAPI DocApache Axis 1.41631Sat Apr 22 18:57:26 BST 2006test.utils

ConsumerPipe

public class ConsumerPipe extends Object implements Runnable

(Omit source code)

Fields Summary
PipedInputStream
consumer
String
result
private static int
pipecount
boolean
done
Constructors Summary
public ConsumerPipe(PipedOutputStream out)

    
         
        consumer = new PipedInputStream(out);
        pipecount++;
Methods Summary
public java.lang.StringgetResult()
Starts this object as a thread, which results in the run() method being invoked and work being done.

        Thread reader = new Thread(this, "Piper-"+pipecount);
        reader.start();
        while (!done) {
            synchronized (this) {
                try {
                    wait();
                } catch (InterruptedException e) {
                }
            }
        }
        return result;
public voidrun()

        try
        {
            char[] chars = new char[consumer.available()];
            for (int i =0; i < chars.length; i++)
            {
                chars[i] = (char)consumer.read();
            }
            result = new String(chars);
        }
        catch (IOException ioe)
        {
            ioe.printStackTrace();
        }
        finally {
            try {
                consumer.close();
            }
            catch (IOException e) {
                e.printStackTrace();
            }
            done = true;
            synchronized (this) {
                notifyAll();
            }
        }