org.jboss.remoting.transport.multiplex.utility
Class GrowablePipedInputStream

java.lang.Object
  extended byjava.io.InputStream
      extended byorg.jboss.remoting.transport.multiplex.utility.GrowablePipedInputStream
Direct Known Subclasses:
MultiplexingInputStream

public class GrowablePipedInputStream
extends java.io.InputStream

A GrowablePipedInputStream.

Version:
$Revision: 1.6 $

Copyright (c) 2005

Author:
Ron Sigal

Field Summary
protected static org.jboss.logging.Logger log
           
 
Constructor Summary
GrowablePipedInputStream()
          Create a new GrowablePipedInputStream.
GrowablePipedInputStream(GrowablePipedOutputStream source)
          Create a new GrowablePipedInputStream.
 
Method Summary
 int available()
           
protected  void connect(GrowablePipedOutputStream source)
           
 int getTimeout()
           
protected  boolean isConnected()
           
 int read()
           
 int read(byte[] bytes)
           
 int read(byte[] bytes, int offset, int length)
           
protected  void receive(byte[] bytes)
           
protected  void receive(byte[] bytes, int offset, int length)
           
protected  void receive(int i)
           
 void setTimeout(int timeout)
           
 
Methods inherited from class java.io.InputStream
close, 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

GrowablePipedInputStream

public GrowablePipedInputStream()
Create a new GrowablePipedInputStream.


GrowablePipedInputStream

public GrowablePipedInputStream(GrowablePipedOutputStream source)
                         throws java.io.IOException
Create a new GrowablePipedInputStream.

Throws:
java.io.IOException
Method Detail

available

public int available()

getTimeout

public int getTimeout()

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 offset,
                int length)
         throws java.io.IOException
Throws:
java.io.IOException

setTimeout

public void setTimeout(int timeout)

connect

protected void connect(GrowablePipedOutputStream source)
                throws java.io.IOException
Throws:
java.io.IOException

isConnected

protected boolean isConnected()

receive

protected void receive(int i)

receive

protected void receive(byte[] bytes)
                throws java.io.IOException
Throws:
java.io.IOException

receive

protected void receive(byte[] bytes,
                       int offset,
                       int length)


Copyright ? 1998-2005 JBoss Inc . All Rights Reserved.