org.barracudamvc.plankton.io
Class BetterPipedInputStream
java.lang.Object
java.io.InputStream
org.barracudamvc.plankton.io.BetterPipedInputStream
- All Implemented Interfaces:
- Closeable
public class BetterPipedInputStream
- extends InputStream
An InputStream that functions just like BetterPipedReader.
See BetterPipedReader
for more information and javadocs.
- Since:
- saw_032304_1
- Author:
- shawnw@atmreports.com
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
logger
protected static final org.apache.log4j.Logger logger
DEFAULT_PIPE_SIZE
public static int DEFAULT_PIPE_SIZE
DEFAULT_TIMEOUT
public static int DEFAULT_TIMEOUT
closedByWriter
protected boolean closedByWriter
closedByReader
protected boolean closedByReader
connected
protected boolean connected
notifiedFirst
protected boolean notifiedFirst
pausable
protected Pausable pausable
readSide
protected Thread readSide
writeSide
protected Thread writeSide
pipeSize
protected int pipeSize
timeout
protected int timeout
buffer
protected byte[] buffer
bufsize
protected int bufsize
in
protected int in
out
protected int out
BetterPipedInputStream
public BetterPipedInputStream()
BetterPipedInputStream
public BetterPipedInputStream(Pausable ipausable,
int ipipeSize)
BetterPipedInputStream
public BetterPipedInputStream(BetterPipedOutputStream src)
throws IOException
- Throws:
IOException
setPipeSize
public void setPipeSize(int ipipeSize)
getPipeSize
public int getPipeSize()
setPipeTimeout
public void setPipeTimeout(int itimeout)
getPipeTimeout
public int getPipeTimeout()
setPausable
public void setPausable(Pausable ipausable)
getPausable
public Pausable getPausable()
connect
public void connect(BetterPipedOutputStream src)
throws IOException
- Throws:
IOException
receive
protected void receive(byte b)
throws IOException
- Throws:
IOException
receive
protected void receive(byte[] b,
int off,
int len)
throws IOException
- Throws:
IOException
receivedFirst
protected void receivedFirst()
receivedLast
protected void receivedLast()
read
public int read()
throws IOException
- Specified by:
read
in class InputStream
- Throws:
IOException
read
public int read(byte[] bbuf,
int off,
int len)
throws IOException
- Overrides:
read
in class InputStream
- Throws:
IOException
ready
public boolean ready()
throws IOException
- Throws:
IOException
close
public void close()
throws IOException
- Specified by:
close
in interface Closeable
- Overrides:
close
in class InputStream
- Throws:
IOException
Copyright © 2006 BarracudaMVC.org All Rights Reserved.