Struct stream_processor_test::Stream

pub struct Stream<'a> {
    pub format_details_version_ordinal: u64,
    pub stream_lifetime_ordinal: u64,
    pub input_buffer_ordinals: &'a mut OrdinalSequence,
    pub input_packet_stream: Option<InputPacketStream<Box<dyn Iterator<Item = ElementaryStreamChunk> + 'a>>>,
    pub output_buffer_ordinals: &'a mut OrdinalSequence,
    pub output_buffer_set: Option<BufferSet>,
    pub current_output_format: Option<Rc<ValidStreamOutputFormat>>,
    pub stream_processor: &'a mut StreamProcessorProxy,
    pub stream: &'a dyn ElementaryStream,
    pub options: StreamOptions,
    pub output: Vec<Output>,
}

Fields

format_details_version_ordinal: u64

stream_lifetime_ordinal: u64

input_buffer_ordinals: &'a mut OrdinalSequence

input_packet_stream: Option<InputPacketStream<Box<dyn Iterator<Item = ElementaryStreamChunk> + 'a>>>

output_buffer_ordinals: &'a mut OrdinalSequence

output_buffer_set: Option<BufferSet>

current_output_format: Option<Rc<ValidStreamOutputFormat>>

stream_processor: &'a mut StreamProcessorProxy

stream: &'a dyn ElementaryStream

options: StreamOptions

output: Vec<Output>

Implementations

impl<'a: 'b, 'b> Stream<'a>

pub async fn start(&'b mut self) -> Result<()>

pub async fn handle_event( &'b mut self, event: StreamProcessorEvent, ) -> Result<StreamControlFlow>