|
| |
|
| java.lang.Object
 java.io.OutputStream
org.cougaar.util.PipedOutputStream
| PipedOutputStream | | public class PipedOutputStream extends java.io.OutputStream (Code) | | An efficient implementation of PipedOutputStream
|
| Method Summary | |
| public synchronized void | close()
Close this stream. | | public synchronized void | connect(PipedInputStream pis)
Connect an PipedInputStream to this. | | public synchronized void | flush()
Insure that all bytes that have been written are accessible to
the reader of the connected PipedInputStream. | | public synchronized void | write(int b)
Write a byte to the pipe. | | public synchronized void | write(byte[] b, int off, int len)
Write an array of bytes to the pipe. | | public synchronized void | write(byte[] b)
Write part of an array of bytes to the pipe. |
| PipedOutputStream | | public PipedOutputStream()(Code) | | Create an unconnected PipedOutputStream. To be used this must be
passed to a new PipedInputStream or a new PipedInputStream must
be connected to this.
|
| PipedOutputStream | | public PipedOutputStream(PipedInputStream pis)(Code) | | Create an PipedOutputStream connected to the given
PipedInputStream. The pair of streams is immediately ready to be
used if this constructor is used.
Parameters:
pis - the PipedInputStream to connect to this. |
| close | | public synchronized void close() throws IOException(Code) | | Close this stream. The connection PipedInputStream will signal
EOF when all the bytes have been read.
exception:
IOException - if this stream is already closed |
| connect | | public synchronized void connect(PipedInputStream pis)(Code) | | Connect an PipedInputStream to this. This must be unconnected.
Parameters:
pis - the PipedInputStream to connect. |
| flush | | public synchronized void flush() throws IOException(Code) | | Insure that all bytes that have been written are accessible to
the reader of the connected PipedInputStream.
exception:
IOException - if this stream is closed or not connected. |
| write | | public synchronized void write(int b) throws IOException(Code) | | Write a byte to the pipe. The byte is put into the connected
PipedInputStream.
Parameters:
b - the byte to put.
exception:
IOException - if this stream is closed or not connectedor connected to a closed PipedInputStream. |
| write | | public synchronized void write(byte[] b, int off, int len) throws IOException(Code) | | Write an array of bytes to the pipe. All the bytes in the array
are put into the connected PipedInputStream.
Parameters:
b - the byte to put.
exception:
IOException - if this stream is closed or not connectedor connected to a closed PipedInputStream. |
| write | | public synchronized void write(byte[] b) throws IOException(Code) | | Write part of an array of bytes to the pipe. Some of the bytes in
the array are put into the connected PipedInputStream.
Parameters:
b - the byte to put.
exception:
IOException - if this stream is closed or not connectedor connected to a closed PipedInputStream. |
|
|
|