Struct StreamProcessor

pub struct StreamProcessor { /* private fields */ }

Struct representing a CodecFactory . Input sent to the encoder via StreamProcessor::write_bytes is queued for delivery, and delivered whenever a packet is full or StreamProcessor::send_packet is called. Output can be retrieved using an StreamProcessorStream from StreamProcessor::take_output_stream.

Implementations

impl StreamProcessor

pub fn create_encoder( input_domain: DomainFormat, encoder_settings: EncoderSettings, ) -> Result<StreamProcessor, Error>

Create a new StreamProcessor encoder, with the given input_domain and encoder_settings. See stream_processor.fidl for descriptions of these parameters. This is only meant for audio encoding.

pub fn create_decoder( mime_type: &str, oob_bytes: Option<Vec<u8>>, ) -> Result<StreamProcessor, Error>

Create a new StreamProcessor decoder, with the given mime_type and optional oob_bytes. See stream_processor.fidl for descriptions of these parameters. This is only meant for audio decoding.

pub fn take_output_stream( &mut self, ) -> Result<StreamProcessorOutputStream, Error>

Take a stream object which will produce the output of the processor. Only one StreamProcessorOutputStream object can exist at a time, and this will return an Error if it is already taken.

pub fn send_packet(&mut self) -> Result<(), Error>

Flush the input buffer to the processor, relinquishing the ownership of the buffer currently in the input cursor, and picking a new input buffer. If there is no input buffer left, the input cursor is left as None.

pub fn close(&mut self) -> Result<(), Error>

Trait Implementations

impl AsyncWrite for StreamProcessor

fn poll_write( self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &[u8], ) -> Poll<Result<usize>>

Attempt to write bytes from buf into the object.

fn poll_flush(self: Pin<&mut Self>, _: &mut Context<'_>) -> Poll<Result<()>>

Attempt to flush the object, ensuring that any buffered data reach their destination.

fn poll_close(self: Pin<&mut Self>, _: &mut Context<'_>) -> Poll<Result<()>>

Attempt to close the object.

fn poll_write_vectored( self: Pin<&mut Self>, cx: &mut Context<'_>, bufs: &[IoSlice<'_>], ) -> Poll<Result<usize, Error>>

Attempt to write bytes from bufs into the object using vectored IO operations.