Struct BoxedSourceCancelSafe

pub struct BoxedSourceCancelSafe<M: MediaType>(/* private fields */);

BoxedSource with NextEventIsCancelSafe implemented

Implementations

impl<M: MediaType> BoxedSourceCancelSafe<M>

pub fn new(source: impl Source<MediaType = M> + NextEventIsCancelSafe) -> Self

pub fn downcast<T: Source<MediaType = M>>(self) -> Result<Box<T>, Self>

pub fn downcast_ref<T: Source<MediaType = M>>(&self) -> Option<&T>

pub fn downcast_mut<T: Source<MediaType = M>>(&mut self) -> Option<&mut T>

Trait Implementations

impl<M: MediaType> Source for BoxedSourceCancelSafe<M>

type MediaType = M

async fn capabilities( &mut self, ) -> Result<Vec<<Self::MediaType as MediaType>::ConfigRange>>

async fn negotiate_config( &mut self, available: Vec<<Self::MediaType as MediaType>::ConfigRange>, ) -> Result<<Self::MediaType as MediaType>::Config>

Provide a list of available configurations ranges. Upstream sources then filter out invalid/incompatible configs until the “root” source then decides on the streaming config, which is then returned down the source stack. This must always be called before trying to call Source::next_event.

async fn next_event(&mut self) -> Result<SourceEvent<Self::MediaType>>

Fetch the next event from the source. This method should be called as much as possible to allow source to drive their internal logic without having to rely on extra tasks.

fn boxed(self) -> BoxedSource<Self::MediaType>

Erase the type of this source

fn boxed_cancel_safe(self) -> BoxedSourceCancelSafe<Self::MediaType>

where Self: NextEventIsCancelSafe,

Erase the type of this source, keeping the information that the next_event future is cancel safe

impl<M: MediaType> NextEventIsCancelSafe for BoxedSourceCancelSafe<M>