anon.shared

Class ChannelInputStream

java.lang.Object

java.io.InputStream

anon.shared.ChannelInputStream

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

final class ChannelInputStream
extends java.io.InputStream

Field Summary

Fields

Modifier and Type	Field and Description
private boolean	m_bIsClosed
private IOQueue	m_Queue

Constructor Summary

Constructors

Constructor and Description
ChannelInputStream(AbstractAnonChannel c)

Method Summary

Modifier and Type	Method and Description
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(AbstractAnonChannel 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

Specified by:

close in interface java.lang.AutoCloseable

Overrides:

close in class java.io.InputStream

Throws:

java.io.IOException