Struct StreamingLoader 

pub struct StreamingLoader { /* private fields */ }

Streaming loader for continuous fragment loading

Implementations

impl StreamingLoader

pub fn new( loader: Arc<NetworkLoader>, path_prefix: impl Into<String>, buffer: usize, ) -> Self

Create a new streaming loader

pub async fn start(&mut self, requests: Vec<LoadRequest>)

Start loading fragments

pub async fn next(&mut self) -> Option<LoadResult>

Receive next result

pub async fn next_timeout(&mut self, timeout: Duration) -> Option<LoadResult>

Receive with timeout