Struct audio_streams::shm_streams::MockShmStream

pub struct MockShmStream {
    num_channels: usize,
    frame_rate: u32,
    request_size: usize,
    frame_size: usize,
    request_notifier: Arc<(Mutex<bool>, Condvar)>,
}

Fields

num_channels: usize

frame_rate: u32

request_size: usize

frame_size: usize

request_notifier: Arc<(Mutex<bool>, Condvar)>

Implementations

impl MockShmStream

pub fn new( num_channels: usize, frame_rate: u32, format: SampleFormat, buffer_size: usize ) -> Self

Attempt to create a new MockShmStream with the given number of channels, frame_rate, format, and buffer_size.

pub fn trigger_callback_with_timeout(&mut self, timeout: Duration) -> bool

Call to request data from the stream, causing it to return from wait_for_next_action_with_timeout. Will block until set_buffer_offset_and_frames is called on the ServerRequest returned from wait_for_next_action_with_timeout, or until timeout elapses. Returns true if a response was successfully received.

fn notify_request(&mut self)

Trait Implementations

impl BufferSet for MockShmStream

fn callback(&mut self, _offset: usize, _frames: usize) -> Result<(), BoxError>

Called when the client sets a buffer offset and length.

fn ignore(&mut self) -> Result<(), BoxError>

Called when the client ignores a request from the server.

impl Clone for MockShmStream

fn clone(&self) -> MockShmStream

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl ShmStream for MockShmStream

fn frame_size(&self) -> usize

Get the size of a frame of audio data for this stream.

fn num_channels(&self) -> usize

Get the number of channels of audio data for this stream.

fn frame_rate(&self) -> u32

Get the frame rate of audio data for this stream.

fn wait_for_next_action_with_timeout( &mut self, timeout: Duration ) -> Result<Option<ServerRequest<'_>>, BoxError>

Waits until the next server message indicating action is required.