| java.lang.Object com.caucho.vfs.StreamImpl com.caucho.vfs.PipeStream
PipeStream | public class PipeStream extends StreamImpl (Code) | | Stream allowing two threads to read and write to each other.
|
Method Summary | |
public boolean | canRead() | public boolean | canWrite() The pipe stream can write. | public void | close() | public static Object[] | create() Creates a pipe pair. | public int | getAvailable() Return the available bytes. | public int | read(byte[] buf, int offset, int length) Reads the available bytes if any, otherwise block. | public void | write(byte[] buf, int offset, int length, boolean isEnd) Implementation of the pipe write. |
canRead | public boolean canRead()(Code) | | PipeStreams can read
|
canWrite | public boolean canWrite()(Code) | | The pipe stream can write.
|
create | public static Object[] create()(Code) | | Creates a pipe pair. The first object is a ReadStream, the second
is a WriteStream.
|
getAvailable | public int getAvailable() throws IOException(Code) | | Return the available bytes.
|
read | public int read(byte[] buf, int offset, int length) throws IOException(Code) | | Reads the available bytes if any, otherwise block.
|
write | public void write(byte[] buf, int offset, int length, boolean isEnd) throws IOException(Code) | | Implementation of the pipe write.
Parameters: buf - byte buffer containing the bytes Parameters: offset - offset where to start writing Parameters: length - number of bytes to write Parameters: isEnd - true when the write is flushing a close. |
Methods inherited from com.caucho.vfs.StreamImpl | public boolean canRead()(Code)(Java Doc) public boolean canWrite()(Code)(Java Doc) public void clearWrite()(Code)(Java Doc) public void close() throws IOException(Code)(Java Doc) public void closeWrite() throws IOException(Code)(Java Doc) public void flush() throws IOException(Code)(Java Doc) public void flushBuffer() throws IOException(Code)(Java Doc) public void flushToDisk() throws IOException(Code)(Java Doc) public Object getAttribute(String name) throws IOException(Code)(Java Doc) public Iterator getAttributeNames() throws IOException(Code)(Java Doc) public int getAvailable() throws IOException(Code)(Java Doc) public boolean getFlushOnNewline()(Code)(Java Doc) public byte[] getNewline()(Code)(Java Doc) public Path getPath()(Code)(Java Doc) public byte[] getReadBuffer()(Code)(Java Doc) public long getReadPosition()(Code)(Java Doc) public boolean hasSkip()(Code)(Java Doc) public int read(byte[] buffer, int offset, int length) throws IOException(Code)(Java Doc) public int readNonBlock(byte[] buffer, int offset, int length) throws IOException(Code)(Java Doc) public int readTimeout(byte[] buffer, int offset, int length, long timeout) throws IOException(Code)(Java Doc) public void removeAttribute(String name) throws IOException(Code)(Java Doc) public void seekEnd(long offset) throws IOException(Code)(Java Doc) public void seekStart(long offset) throws IOException(Code)(Java Doc) public void setAttribute(String name, Object value) throws IOException(Code)(Java Doc) public void setPath(Path path)(Code)(Java Doc) public void setWriteEncoding(String encoding)(Code)(Java Doc) public long skip(long n) throws IOException(Code)(Java Doc) public void write(byte[] buffer, int offset, int length, boolean isEnd) throws IOException(Code)(Java Doc) public boolean write(byte[] buf1, int off1, int len1, byte[] buf2, int off2, int len2, boolean isEnd) throws IOException(Code)(Java Doc)
|
|
|