org.jboss.remoting.transport.multiplex
Class MultiplexingInputStream

java.lang.Object
  extended byjava.io.InputStream
      extended byjava.io.PipedInputStream
          extended byorg.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
 
Constructor Summary
MultiplexingInputStream(java.io.PipedOutputStream sourceStream)
           
MultiplexingInputStream(java.io.PipedOutputStream sourceStream, VirtualSocket socket)
           
 
Method Summary
 void close()
           
protected  void handleRemoteShutdown()
          FIXME Comment this
 int read()
           
 int read(byte[] bytes)
           
 int read(byte[] bytes, int off, int len)
           
protected  void setEOF()
           
protected  int timedRead()
          FIXME Comment this
 
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
 

Field Detail

log

protected static final org.jboss.logging.Logger log
Constructor Detail

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
Method Detail

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.