public class

PipedOutputStream

extends OutputStream
java.lang.Object
   ↳ java.io.OutputStream
     ↳ java.io.PipedOutputStream

Class Overview

Places information on a communications pipe. When two threads want to pass data back and forth, one creates a piped output stream and the other one creates a piped input stream.

See Also

Summary

Public Constructors
PipedOutputStream()
Constructs a new unconnected PipedOutputStream.
PipedOutputStream(PipedInputStream target)
Constructs a new PipedOutputStream connected to the PipedInputStream target.
Public Methods
void close()
Closes this stream.
void connect(PipedInputStream stream)
Connects this stream to a PipedInputStream.
void flush()
Notifies the readers of this PipedInputStream that bytes can be read.
void write(byte[] buffer, int offset, int count)
Writes count bytes from the byte array buffer starting at offset to this stream.
void write(int oneByte)
Writes a single byte to this stream.
[Expand]
Inherited Methods
From class java.io.OutputStream
From class java.lang.Object
From interface java.io.Closeable
From interface java.io.Flushable

Public Constructors

public PipedOutputStream ()

Since: API Level 1

Constructs a new unconnected PipedOutputStream. The resulting stream must be connected to a PipedInputStream before data can be written to it.

public PipedOutputStream (PipedInputStream target)

Since: API Level 1

Constructs a new PipedOutputStream connected to the PipedInputStream target. Any data written to this stream can be read from the target stream.

Parameters
target the piped input stream to connect to.
Throws
IOException if this stream or target are already connected.

Public Methods

public void close ()

Since: API Level 1

Closes this stream. If this stream is connected to an input stream, the input stream is closed and the pipe is disconnected.

Throws
IOException if an error occurs while closing this stream.

public void connect (PipedInputStream stream)

Since: API Level 1

Connects this stream to a PipedInputStream. Any data written to this output stream becomes readable in the input stream.

Parameters
stream the piped input stream to connect to.
Throws
IOException if either stream is already connected.

public void flush ()

Since: API Level 1

Notifies the readers of this PipedInputStream that bytes can be read. This method does nothing if this stream is not connected.

Throws
IOException if an I/O error occurs while flushing this stream.

public void write (byte[] buffer, int offset, int count)

Since: API Level 1

Writes count bytes from the byte array buffer starting at offset to this stream. The written data can then be read from the connected input stream.

Separate threads should be used to write to a PipedOutputStream and to read from the connected PipedInputStream. If the same thread is used, a deadlock may occur.

Parameters
buffer the buffer to write.
offset the index of the first byte in buffer to write.
count the number of bytes from buffer to write to this stream.
Throws
IndexOutOfBoundsException if offset < 0 or count < 0, or if offset + count is bigger than the length of buffer.
InterruptedIOException if the pipe is full and the current thread is interrupted waiting for space to write data. This case is not currently handled correctly.
IOException if this stream is not connected, if the target stream is closed or if the thread reading from the target stream is no longer alive. This case is currently not handled correctly.

public void write (int oneByte)

Since: API Level 1

Writes a single byte to this stream. Only the least significant byte of the integer oneByte is written. The written byte can then be read from the connected input stream.

Separate threads should be used to write to a PipedOutputStream and to read from the connected PipedInputStream. If the same thread is used, a deadlock may occur.

Parameters
oneByte the byte to write.
Throws
InterruptedIOException if the pipe is full and the current thread is interrupted waiting for space to write data. This case is not currently handled correctly.
IOException if this stream is not connected, if the target stream is closed or if the thread reading from the target stream is no longer alive. This case is currently not handled correctly.