com.antiaction.mayhem.core
Class BufferedSocketInputStream

java.lang.Object
  java.io.InputStream
      com.antiaction.mayhem.core.BufferedSocketInputStream

All Implemented Interfaces:

IBufferedInputStream, java.io.Closeable

public class BufferedSocketInputStream
extends java.io.InputStream
implements IBufferedInputStream

Buffered Socket InputStream (Timeout support).

Version:

1.00

Author:

Nicholas Clarke

Constructor Summary

BufferedSocketInputStream()
Construct object with default buffer size.

BufferedSocketInputStream(int size)
Construct object with a buffer of the requested size.

Method Summary

int	available()
void	close()
void	init() Initialize the internal structures and indexes.
void	mark(int readlimit)
boolean	markSupported()
void	open(java.net.Socket socket, java.io.InputStream in) Attach an InputStream to this wrapper.
int	read()
int	read(byte[] b)
int	read(byte[] b, int off, int len)
java.lang.String	readLine(byte[] arrReadLine) Reads a line on the supplied InputStream.
int	readLine(byte[] b, int off, int len)
void	reset()
void	setSoTimeout(int soTimeout)
long	skip(long n)

Methods inherited from class java.lang.Object

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

Constructor Detail

BufferedSocketInputStream

public BufferedSocketInputStream()

Construct object with default buffer size.

See Also:

BufferedSocketInputStream(int)

BufferedSocketInputStream

public BufferedSocketInputStream(int size)

Construct object with a buffer of the requested size.

Parameters:

size - initial size of buffer.

Method Detail

init

public void init()

Initialize the internal structures and indexes.

open

public void open(java.net.Socket socket,
                 java.io.InputStream in)

Attach an InputStream to this wrapper.

setSoTimeout

public void setSoTimeout(int soTimeout)

close

public void close()
           throws java.io.IOException

Specified by:

close in interface IBufferedInputStream

Specified by:

close in interface java.io.Closeable

Overrides:

close in class java.io.InputStream

Throws:

java.io.IOException

markSupported

public boolean markSupported()

Specified by:

markSupported in interface IBufferedInputStream

Overrides:

markSupported in class java.io.InputStream

available

public int available()
              throws java.io.IOException

Specified by:

available in interface IBufferedInputStream

Overrides:

available in class java.io.InputStream

Throws:

java.io.IOException

mark

public void mark(int readlimit)

Specified by:

mark in interface IBufferedInputStream

Overrides:

mark in class java.io.InputStream

reset

public void reset()
           throws java.io.IOException

Specified by:

reset in interface IBufferedInputStream

Overrides:

reset in class java.io.InputStream

Throws:

java.io.IOException

read

public int read()
         throws java.io.IOException

Specified by:

read in interface IBufferedInputStream

Specified by:

read in class java.io.InputStream

Throws:

java.io.IOException

read

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

Specified by:

read in interface IBufferedInputStream

Overrides:

read in class java.io.InputStream

Throws:

java.io.IOException

read

public int read(byte[] b,
                int off,
                int len)
         throws java.io.IOException

Specified by:

read in interface IBufferedInputStream

Overrides:

read in class java.io.InputStream

Throws:

java.io.IOException

skip

public long skip(long n)
          throws java.io.IOException

Specified by:

skip in interface IBufferedInputStream

Overrides:

skip in class java.io.InputStream

Throws:

java.io.IOException

readLine

public int readLine(byte[] b,
                    int off,
                    int len)
             throws java.io.IOException

Specified by:

readLine in interface IBufferedInputStream

Throws:

java.io.IOException

readLine

public java.lang.String readLine(byte[] arrReadLine)
                          throws java.io.IOException

Reads a line on the supplied InputStream. Lines over 4096 are split.

Specified by:

readLine in interface IBufferedInputStream

Returns:

the read line.

Throws:

java.io.IOException