Package net.avadeaux.klipspringer.encoder

Class EncoderChannelStreamLine

java.lang.Object

net.avadeaux.klipspringer.encoder.PlayerState

net.avadeaux.klipspringer.encoder.ChannelStreamLine

net.avadeaux.klipspringer.encoder.EncoderChannelStreamLine

All Implemented Interfaces:

AutoCloseable, DataLine, Line, SourceDataLine

Direct Known Subclasses:

FlacChannelStreamLine, LameChannelStreamLine

public abstract class EncoderChannelStreamLine
extends ChannelStreamLine

Abstract line that organizes audio channels in separate buffers.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static interface	EncoderChannelStreamLine.EncoderFactory	Factory interface for subclasses to provide the constructor with a way of producing an encoder handle.

Nested classes/interfaces inherited from interface javax.sound.sampled.DataLine

DataLine.Info

Field Summary

Fields

Modifier and Type	Field	Description
protected final ByteBuffer[]	buf

Fields inherited from class net.avadeaux.klipspringer.encoder.ChannelStreamLine

bc, bips, bsam, byps, dsam, esam, fs

Constructor Summary

Constructors

Constructor	Description
EncoderChannelStreamLine(WritableByteChannel bc, AudioFormat format, long writeAheadMillis, long timeoutMillis, int bufferSamples, EncoderChannelStreamLine.EncoderFactory efact)	bc should not be non-blocking.

Method Summary

Modifier and Type	Method	Description
int	available()
protected int	bufferedSamples()	Number of bytes received by the line but not yet sent to the channel.
void	close()	Closes the line and the destination channel, without writing anything.
void	finish()	Emits buffered data and any data buffered in encoder.
protected abstract void	finish(long handle)
void	flush()	Discards buffered data that has not yet been written to the channel.
protected abstract void	free(long handle)
int	getBufferSize()
protected long	outputSamples()	Number of samples known to have been sent to the client endpoint for playing.
protected abstract long	outputSamples(long handle)
protected void	writeBuffer()	Writes data buffered on the line to the channel.
protected abstract void	writeBuffer(long handle, int samples)

Methods inherited from class net.avadeaux.klipspringer.encoder.ChannelStreamLine

addLineListener, drain, getControl, getControls, getFormat, getFramePosition, getLevel, getLineInfo, getLongFramePosition, getMicrosecondPosition, isActive, isControlSupported, isRunning, open, open, open, removeLineListener, start, stop

Methods inherited from class net.avadeaux.klipspringer.encoder.PlayerState

isOpen, onClose, playedMillis, playedMillis, waitForPlayed

Methods inherited from class java.lang.Object

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

Methods inherited from interface javax.sound.sampled.Line

isOpen

Methods inherited from interface javax.sound.sampled.SourceDataLine

write

Field Details

buf

protected final ByteBuffer[] buf

Constructor Details

EncoderChannelStreamLine

public EncoderChannelStreamLine(WritableByteChannel bc,
 AudioFormat format,
 long writeAheadMillis,
 long timeoutMillis,
 int bufferSamples,
 EncoderChannelStreamLine.EncoderFactory efact)
                         throws IOException,
UnsupportedAudioFileException

bc should not be non-blocking.

Throws:

IOException

UnsupportedAudioFileException

Method Details

bufferedSamples

protected int bufferedSamples()

Description copied from class: ChannelStreamLine

Number of bytes received by the line but not yet sent to the channel.

Specified by:

bufferedSamples in class ChannelStreamLine

writeBuffer

protected void writeBuffer()
                    throws IOException

Description copied from class: ChannelStreamLine

Writes data buffered on the line to the channel.

Specified by:

writeBuffer in class ChannelStreamLine

Throws:

IOException

flush

public void flush()

Discards buffered data that has not yet been written to the channel.

finish

public void finish()

Description copied from class: ChannelStreamLine

Emits buffered data and any data buffered in encoder. Default implementation just calls drain.

Overrides:

finish in class ChannelStreamLine

close

public void close()

Description copied from class: ChannelStreamLine

Closes the line and the destination channel, without writing anything. In order for all data to be emitted, finish should be called before close.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Line

Overrides:

close in class ChannelStreamLine

getBufferSize

public int getBufferSize()

available

public int available()

outputSamples

protected long outputSamples()

Description copied from class: ChannelStreamLine

Number of samples known to have been sent to the client endpoint for playing. The default implementation returns the number of samples sent to the channel. Needs to be overridden if there is buffering/compression from this point that may cause a delay in the client playing. The number returned by this method may be slightly lower than the actual number output to the endpoint but must never be higher.

Overrides:

outputSamples in class ChannelStreamLine

writeBuffer

protected abstract void writeBuffer(long handle,
 int samples)
                             throws IOException

Throws:

IOException

finish

protected abstract void finish(long handle)
                        throws IOException

Throws:

IOException

free

protected abstract void free(long handle)

outputSamples

protected abstract long outputSamples(long handle)