io.apigee.trireme.kernel.streams

Class CircularByteBuffer

java.lang.Object

io.apigee.trireme.kernel.streams.CircularByteBuffer

public class CircularByteBuffer
extends Object

A simple circular buffer that grows as needed.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	CircularByteBuffer.CircularByteBufferInputStream InputStream wrapper around the buffer
class	CircularByteBuffer.CircularByteBufferOutputStream OutputStream wrapper around the buffer

Field Summary

Fields

Modifier and Type	Field and Description
protected byte[]	buf
static int	DEFAULT_SIZE
protected CircularByteBuffer.CircularByteBufferInputStream	inputStream
protected CircularByteBuffer.CircularByteBufferOutputStream	outputStream
protected int	readPos
protected int	writePos

Constructor Summary

Constructors

Constructor and Description
CircularByteBuffer()
CircularByteBuffer(int initialCapacity)

Method Summary

Methods

Modifier and Type	Method and Description
int	available()
void	clear()
int	freeCapacity()
CircularByteBuffer.CircularByteBufferInputStream	getInputStream()
CircularByteBuffer.CircularByteBufferOutputStream	getOutputStream()
boolean	hasAvailable()
int	peek(byte[] out)
int	peek(byte[] out, int offset, int len)
int	read()
int	read(byte[] out)
int	read(byte[] out, int offset, int len)
void	resize(int newSize)
long	skip(long len)
int	totalCapacity()
int	write(byte[] in, int offset, int len)
int	write(int i)

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_SIZE

public static final int DEFAULT_SIZE

See Also:

Constant Field Values

buf

protected byte[] buf

readPos

protected int readPos

writePos

protected int writePos

inputStream

protected final CircularByteBuffer.CircularByteBufferInputStream inputStream

outputStream

protected final CircularByteBuffer.CircularByteBufferOutputStream outputStream

Constructor Detail

CircularByteBuffer

public CircularByteBuffer()

CircularByteBuffer

public CircularByteBuffer(int initialCapacity)

Method Detail

clear

public void clear()

read

public int read()

read

public int read(byte[] out,
       int offset,
       int len)

read

public int read(byte[] out)

write

public int write(int i)

write

public int write(byte[] in,
        int offset,
        int len)

skip

public long skip(long len)

peek

public int peek(byte[] out,
       int offset,
       int len)

peek

public int peek(byte[] out)

resize

public void resize(int newSize)

available

public int available()

hasAvailable

public boolean hasAvailable()

totalCapacity

public int totalCapacity()

freeCapacity

public int freeCapacity()

getInputStream

public CircularByteBuffer.CircularByteBufferInputStream getInputStream()

getOutputStream

public CircularByteBuffer.CircularByteBufferOutputStream getOutputStream()