anon.shared
Class ChannelInputStream

java.lang.Object
  java.io.InputStream
      anon.shared.ChannelInputStream

All Implemented Interfaces:

java.io.Closeable

final class ChannelInputStream
extends java.io.InputStream

Field Summary

private boolean	m_bIsClosed
private IOQueue	m_Queue

Constructor Summary

ChannelInputStream(AbstractChannel c)

Method Summary

int	available()
void	close()
protected void	closedByPeer()
int	read()
int	read(byte[] out)
int	read(byte[] out, int pos, int len)
protected void	recv(byte[] buff, int pos, int len)

Methods inherited from class java.io.InputStream

mark, markSupported, reset, skip

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

m_Queue

private IOQueue m_Queue

m_bIsClosed

private boolean m_bIsClosed

Constructor Detail

ChannelInputStream

ChannelInputStream(AbstractChannel c)

Method Detail

recv

protected void recv(byte[] buff,
                    int pos,
                    int len)
             throws java.io.IOException

Throws:

java.io.IOException

available

public int available()
              throws java.io.IOException

Overrides:

available in class java.io.InputStream

Throws:

java.io.IOException

read

public int read()
         throws java.io.IOException

Specified by:

read in class java.io.InputStream

Throws:

java.io.IOException

read

public int read(byte[] out)
         throws java.io.IOException

Overrides:

read in class java.io.InputStream

Throws:

java.io.IOException

read

public int read(byte[] out,
                int pos,
                int len)
         throws java.io.IOException

Overrides:

read in class java.io.InputStream

Throws:

java.io.IOException

closedByPeer

protected void closedByPeer()

close

public void close()
           throws java.io.IOException

Specified by:

close in interface java.io.Closeable

Overrides:

close in class java.io.InputStream

Throws:

java.io.IOException