moq-karp 0.5.0

Media over QUIC
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28

use std::time;

use moq_transfork::{Path, Session};

use super::Broadcast;

pub struct Resumable {
	session: Session,
	path: Path,
}

impl Resumable {
	pub fn new(session: Session, path: Path) -> Self {
		Self { session, path }
	}

	/// Produce a broadcast using the current time as the ID.
	/// This can be used across restarts to resume a broadcast... provided you don't reset your clock.
	pub fn broadcast(&self) -> Broadcast {
		let id = time::SystemTime::now()
			.duration_since(time::UNIX_EPOCH)
			.unwrap()
			.as_secs();

		let path = self.path.clone().push(id.to_string());
		Broadcast::new(self.session.clone(), path)
	}
}