Struct Stream

pub struct Stream {
    stream_id: u32,
    receiver: Receiver<Box<StreamMsg>>,
    vios_client: Arc<Mutex<VioSClient>>,
    control_queue: Arc<Mutex<Queue>>,
    io_queue: Arc<Mutex<Queue>>,
    capture: bool,
    current_state: StreamState,
    period: Duration,
    start_time: Instant,
    next_buffer: Duration,
    buffer_queue: VecDeque<DescriptorChain>,
}

Fields

stream_id: u32

receiver: Receiver<Box<StreamMsg>>

vios_client: Arc<Mutex<VioSClient>>

control_queue: Arc<Mutex<Queue>>

io_queue: Arc<Mutex<Queue>>

capture: bool

current_state: StreamState

period: Duration

start_time: Instant

next_buffer: Duration

buffer_queue: VecDeque<DescriptorChain>

Implementations

impl Stream

pub fn try_new( stream_id: u32, vios_client: Arc<Mutex<VioSClient>>, control_queue: Arc<Mutex<Queue>>, io_queue: Arc<Mutex<Queue>>, capture: bool, stream_state: Option<StreamSnapshot>, ) -> Result<StreamProxy>

Start a new stream thread and return its handler.

fn stream_loop(&mut self) -> Result<()>

fn recv_msg(&mut self) -> Result<bool>

fn maybe_process_queued_buffers(&mut self) -> Result<()>

Trait Implementations

impl Drop for Stream

fn drop(&mut self)

Executes the destructor for this type.