Struct stream_processor_test::Stream
source · 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§
source§impl<'a: 'b, 'b> Stream<'a>
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>
Auto Trait Implementations§
impl<'a> Freeze for Stream<'a>
impl<'a> !RefUnwindSafe for Stream<'a>
impl<'a> !Send for Stream<'a>
impl<'a> !Sync for Stream<'a>
impl<'a> Unpin for Stream<'a>
impl<'a> !UnwindSafe for Stream<'a>
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more