Struct AsyncRingSourceProvider 

pub struct AsyncRingSourceProvider { /* private fields */ }

A ringbuffer Producer meant for wrapping Source to make decode & playback async and keep the buffer filled without having audible gaps.

The implementation of the Producer is meant for async code, awaiting to fully put data on the ringbuffer OR waiting for seek events.

Implementations

impl AsyncRingSourceProvider

pub fn is_closed(&self) -> bool

Check if the consumer (AsyncRingSource) is still connected and writes are possible

pub async fn new_spec( &mut self, spec: SignalSpec, current_span_len: usize, ) -> Result<usize, ()>

Write a new spec.

Returns Ok(count) if the message is written, with the length, Err if closed.

Errors

Ringbuffer closed and no more data available.

pub async fn write_data(&mut self, data: &[u8]) -> Result<usize, ()>

Write a given buffer as a data message.

Returns Ok(count) if the message is written, with the length, Err if closed.

Errors

Ringbuffer closed and no more data available.

pub async fn new_eos(&mut self) -> Result<usize, ()>

Write a EOS message.

Returns Ok(count) if the message is written, with the length, Err if closed.

Errors

Ringbuffer closed and no more data available.

pub fn wait_seek(&mut self) -> WaitSeek

Wait until the seek channel is dropped(None) or a seek is requested(Some).

pub async fn process_seek( &mut self, spec: SignalSpec, current_span_len: usize, cb: Sender<usize>, )

Process a seek and call the Consumer to resume.

This clear all data state, calls the consumer to resume with how many bytes to skip and sends the new spec (in case it changed in the seek).

Trait Implementations

impl Debug for AsyncRingSourceProvider

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

Formats the value using the given formatter.