net.sf.fmj.media
Class BufferQueueInputStream

java.lang.Object
  java.io.InputStream
      net.sf.fmj.media.BufferQueueInputStream

All Implemented Interfaces:

java.io.Closeable

public class BufferQueueInputStream
extends java.io.InputStream

Turns a queue of Buffer objects into an InputStream.

Author:

Ken Larson

Constructor Summary

BufferQueueInputStream()

BufferQueueInputStream(int qSize)

BufferQueueInputStream(ProducerConsumerQueue q)

Method Summary

int	available()
void	blockingPut(Buffer b)
void	blockingPut(Buffer b, boolean clone)
boolean	put(Buffer b)
boolean	put(Buffer b, boolean clone)
int	read()
int	read(byte[] b, int off, int len)
void	setTrace(boolean value)

Methods inherited from class java.io.InputStream

close, mark, markSupported, read, reset, skip

Methods inherited from class java.lang.Object

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

Constructor Detail

BufferQueueInputStream

public BufferQueueInputStream()

BufferQueueInputStream

public BufferQueueInputStream(int qSize)

BufferQueueInputStream

public BufferQueueInputStream(ProducerConsumerQueue q)

Method Detail

setTrace

public void setTrace(boolean value)

put

public boolean put(Buffer b)

blockingPut

public void blockingPut(Buffer b)

put

public boolean put(Buffer b,
                   boolean clone)

blockingPut

public void blockingPut(Buffer b,
                        boolean clone)

available

public int available()

Overrides:

available in class java.io.InputStream

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[] b,
                int off,
                int len)
         throws java.io.IOException

Overrides:

read in class java.io.InputStream

Throws:

java.io.IOException