    All Packages  Class Hierarchy  This Package  Previous  Next  Index

# Class org.w3c.www.mux.MuxOutputStream

    java.lang.Object
       |
       +----java.io.OutputStream
               |
               +----org.w3c.www.mux.MuxOutputStream

public class MuxOutputStream
extends OutputStream

##

avail_credit
  The currently available credit.
closed
  Has this stream been closed ?
debug
fragsz
  The current max allowed fragment size.
sessid
  The identifier of above session (fast access).
session
  The session this stream is attached to.
writer
  The writer instance for the multiplexed stream.

##

MuxOutputStream(MuxSession)

##

close()
  Close that session output stream.
flush()
  Flush that output stream, blocking all data has been sent.
notifyControl(int)
  Callback notifying the the frgament size has changed.
notifyCredit(int)
  Callback notifying that more credit is available for that stream.
write(byte[], int, int)
  Writes a sub array of bytes.
write(int)
  Writes a byte.

##

debug

     protected static final boolean debug

session

     protected MuxSession session

  The session this stream is attached to.

sessid

     protected int sessid

  The identifier of above session (fast access).

writer

     protected MuxWriter writer

  The writer instance for the multiplexed stream.

fragsz

     protected int fragsz

  The current max allowed fragment size.

avail_credit

     protected int avail_credit

  The currently available credit.

closed

     protected boolean closed

  Has this stream been closed ?

##

MuxOutputStream

     protected MuxOutputStream(MuxSession session)

##

notifyCredit

     protected synchronized void notifyCredit(int credit)

  Callback notifying that more credit is available for that stream.

  Parameters:
    credit - The credit we are getting from our peer.

notifyControl

     protected synchronized void notifyControl(int control)

  Callback notifying the the frgament size has changed.

  Parameters:
    control - The new fragment size.

write

     public void write(int b) throws IOException

  Writes a byte. This method will block until the byte is actually written. It is highly recomended that you use a buffered output stream on top of that stream, or that you don't use that method.

  Parameters:
    b - the byte
  Throws: IOException
    If an I/O error has occurred.
  Overrides:
    write in class OutputStream

write

     public void write(byte b[],
                       int off,
                       int len) throws IOException

  Writes a sub array of bytes.

  Parameters:
    b - the data to be written
    off - the start offset in the data
    len - the number of bytes that are written
  Throws: IOException
    If an I/O error has occurred.
  Overrides:
    write in class OutputStream

flush

     public void flush() throws IOException

  Flush that output stream, blocking all data has been sent.

  Throws: IOException
    If some IO errors occur.
  Overrides:
    flush in class OutputStream

close

     public synchronized void close() throws IOException

  Close that session output stream.

  Throws: IOException
    If some IO errors occur.
  Overrides:
    close in class OutputStream

    All Packages  Class Hierarchy  This Package  Previous  Next  Index