MuxInputStream

java.lang.Object

java.io.InputStream

com.caucho.hessian.mux.MuxInputStream

All Implemented Interfaces:: Closeable, AutoCloseable

public class MuxInputStream extends InputStream

Input stream to a specific channel.

Field Summary

Fields

Modifier and Type

Field

Description

protected InputStream

is
Constructor Summary

Constructors

Constructor

Description

MuxInputStream()

Null argument constructor.
Method Summary

Modifier and Type

Method

Description

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.

protected String

readUTF()

Reads a UTF-8 string.

Methods inherited from class java.io.InputStream
available, mark, markSupported, nullInputStream, read, read, readAllBytes, readNBytes, readNBytes, reset, skip, skipNBytes, transferTo

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details
- is
  
  protected InputStream is
Constructor Details
- MuxInputStream
  
  public MuxInputStream()
  
  Null argument constructor.
Method Details
- init
  
  protected void init(MuxServer server, int channel) throws IOException
  
  Initialize the multiplexor with input and output streams.
  
  Throws:
  
  IOException
- getInputStream
  
  protected InputStream getInputStream() throws IOException
  
  Gets the raw input stream. Clients will normally not call this.
  
  Throws:
  
  IOException
- getChannel
  
  public int getChannel()
  
  Gets the channel of the connection.
- getURL
  
  public String getURL()
  
  Returns the request's URL
- read
  
  public int read() throws IOException
  
  Writes a data byte to the output stream.
  
  Specified by:
  
  read in class InputStream
  
  Throws:
  
  IOException
- close
  
  public void close() throws IOException
  
  Complete writing to the stream, closing the channel.
  
  Specified by:
  
  close in interface AutoCloseable
  
  Specified by:
  
  close in interface Closeable
  
  Overrides:
  
  close in class InputStream
  
  Throws:
  
  IOException
- readTag
  
  protected void readTag(int tag) throws IOException
  
  Subclasses will extend this to read values.
  
  Throws:
  
  IOException
- readUTF
  
  protected String readUTF() throws IOException
  
  Reads a UTF-8 string.
  
  Returns:
  
  the utf-8 encoded string
  
  Throws:
  
  IOException