org.jboss.remoting.transport.multiplex
Class MultiplexingInputStream
java.lang.Object
java.io.InputStream
java.io.PipedInputStream
org.jboss.remoting.transport.multiplex.MultiplexingInputStream
- public class MultiplexingInputStream
- extends java.io.PipedInputStream
Copyright (c) 2005
- Author:
- Ron Sigal
Field Summary |
protected static org.jboss.logging.Logger |
log
|
Fields inherited from class java.io.PipedInputStream |
buffer, in, out, PIPE_SIZE |
Methods inherited from class java.io.PipedInputStream |
available, connect, receive |
Methods inherited from class java.io.InputStream |
mark, markSupported, reset, skip |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
log
protected static final org.jboss.logging.Logger log
MultiplexingInputStream
public MultiplexingInputStream(java.io.PipedOutputStream sourceStream,
VirtualSocket socket)
throws java.io.IOException
MultiplexingInputStream
public MultiplexingInputStream(java.io.PipedOutputStream sourceStream)
throws java.io.IOException
- Throws:
java.io.IOException
read
public int read()
throws java.io.IOException
- Throws:
java.io.IOException
read
public int read(byte[] bytes)
throws java.io.IOException
- Throws:
java.io.IOException
read
public int read(byte[] bytes,
int off,
int len)
throws java.io.IOException
- Throws:
java.io.IOException
close
public void close()
throws java.io.IOException
- Throws:
java.io.IOException
handleRemoteShutdown
protected void handleRemoteShutdown()
throws java.io.IOException
- FIXME Comment this
- Throws:
java.io.IOException
setEOF
protected void setEOF()
timedRead
protected int timedRead()
throws java.io.IOException
- FIXME Comment this
- Returns:
-
- Throws:
java.io.IOException
Copyright © 1998-2005 JBoss Inc . All Rights Reserved.