Struct spectrusty::audio::carousel::AudioFrameConsumer

pub struct AudioFrameConsumer<T> { /* private fields */ }

Relays AudioBuffer samples to the audio framework output buffers.

Implementations

impl<T> AudioFrameConsumer<T>

pub fn new(
    buffer: AudioBuffer<T>,
    producer_tx: Sender<AudioBuffer<T>>,
    consumer_rx: Receiver<AudioBuffer<T>>
) -> AudioFrameConsumer<T>

Creates a new instance of AudioFrameConsumer.

Prefer to use create_carousel instead.

pub fn reset_cursor(&mut self)

Resets the audio buffer sample cursor.

impl<T> AudioFrameConsumer<T>where
    T: 'static + Copy + Send,

pub fn next_frame(&mut self) -> Result<bool, AudioFrameError>

Attempts to receive the next audio frame from the AudioFrameProducer.

When Ok(true) is returned replaces the current frame buffer with the one received and sends back the current one.

If there is no new buffer waiting in the message queue returns Ok(false).

Returns Err(AudioFrameError) only when sending or receiving buffers failed, which is possible only when the remote end has disconnected.

pub fn current_frame(&self) -> &[T]

Exposes the last received frame buffer as a slice of samples.

pub fn fill_buffer<'a>(
    &mut self,
    target_buffer: &'a mut [T],
    ignore_missing: bool
) -> Result<&'a mut [T], AudioFrameError>

Fills the target_buffer with the received audio frame samples.

Attempts to receive new frame buffers when necessary, repeating the process until the whole buffer is filled or when there are no more buffers waiting in the incoming queue.

Returns the unfilled part of the target buffer in case there were no more frames to receive and ignore_missing was false.

Returns an empty slice if the whole buffer has been filled.

In case ignore_missing is true the last audio frame will be rendered again if there are no more new buffers in the queue.

Returns Err(AudioFrameError) only when sending or receiving buffers failed, which is possible only when the remote end has disconnected.

Trait Implementations

impl<T> Debug for AudioFrameConsumer<T>where
    T: Debug,

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.