org.arl.fjage.connectors

Class PseudoInputStream

java.lang.Object

java.io.InputStream

org.arl.fjage.connectors.PseudoInputStream

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

public class PseudoInputStream
extends java.io.InputStream

An input stream backed by a byte buffer that can be dynamically written to.

Field Summary

Fields

Modifier and Type	Field and Description
protected BlockingByteQueue	q

Constructor Summary

Constructors

Constructor and Description
PseudoInputStream()

Method Summary

Modifier and Type	Method and Description
int	available()
void	clear() Clear the stream buffer.
void	close()
int	read()
int	read(byte[] buf)
int	read(byte[] buf, int ofs, int len)
void	write(byte[] buf) Write a byte buffer to the stream buffer.
void	write(int c) Write a byte to the stream buffer.

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

q

protected final BlockingByteQueue q

Constructor Detail

PseudoInputStream

public PseudoInputStream()

Method Detail

clear

public void clear()

Clear the stream buffer.

write

public void write(int c)
           throws java.io.IOException

Write a byte to the stream buffer.

Throws:

java.io.IOException

write

public void write(byte[] buf)
           throws java.io.IOException

Write a byte buffer to the stream buffer.

Throws:

java.io.IOException

read

public int read()

Specified by:

read in class java.io.InputStream

read

public int read(byte[] buf,
                int ofs,
                int len)

Overrides:

read in class java.io.InputStream

read

public int read(byte[] buf)

Overrides:

read in class java.io.InputStream

available

public int available()

Overrides:

available in class java.io.InputStream

close

public void close()

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Overrides:

close in class java.io.InputStream