com.caucho.hessian.mux
Class MuxInputStream
InputStreamcom.caucho.hessian.mux.MuxInputStream
public class MuxInputStream
extends InputStream
Input stream to a specific channel.
void | close()- Complete writing to the stream, closing the channel.
|
int | getChannel()- Gets the channel of the connection.
|
protected InputStream | getInputStream()- Gets the raw input stream.
|
String | getURL()- Returns the request's URL
|
protected void | init(MuxServer server, int channel)- Initialize the multiplexor with input and output streams.
|
int | read()- Writes a data byte to the output stream.
|
protected void | readTag(int tag)- Subclasses will extend this to read values.
|
(package private) void | readToData(boolean returnOnYield)- Reads tags, until getting data.
|
protected String | readUTF()- Reads a UTF-8 string.
|
(package private) void | setInputStream(InputStream is)
|
private void | skipToEnd()- Skips data until the end of the channel.
|
channel
private int channel
chunkLength
private int chunkLength
is
protected InputStream is
MuxInputStream
public MuxInputStream()
Null argument constructor.
close
public void close()
throws IOException Complete writing to the stream, closing the channel.
getChannel
public int getChannel()
Gets the channel of the connection.
getInputStream
protected InputStream getInputStream()
throws IOException Gets the raw input stream. Clients will normally not call
this.
getURL
public String getURL()
Returns the request's URL
init
protected void init(MuxServer server,
int channel)
throws IOException Initialize the multiplexor with input and output streams.
read
public int read()
throws IOException Writes a data byte to the output stream.
readTag
protected void readTag(int tag)
throws IOException Subclasses will extend this to read values.
readToData
(package private) void readToData(boolean returnOnYield)
throws IOException Reads tags, until getting data.
readUTF
protected String readUTF()
throws IOException Reads a UTF-8 string.
setInputStream
(package private) void setInputStream(InputStream is)
skipToEnd
private void skipToEnd()
throws IOException Skips data until the end of the channel.