moq-transport 0.14.2

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
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48

// SPDX-FileCopyrightText: 2024-2026 Cloudflare Inc., Luke Curley, Mike English and contributors
// SPDX-FileCopyrightText: 2023-2024 Luke Curley and contributors
// SPDX-License-Identifier: MIT OR Apache-2.0

use std::collections::VecDeque;

use super::Watch;

// TODO replace with mpsc or similar
pub struct Queue<T> {
	state: Watch<VecDeque<T>>,
}

impl<T> Clone for Queue<T> {
	fn clone(&self) -> Self {
		Self {
			state: self.state.clone(),
		}
	}
}

impl<T> Default for Queue<T> {
	fn default() -> Self {
		Self {
			state: Default::default(),
		}
	}
}

impl<T> Queue<T> {
	pub fn push(&self, item: T) {
		self.state.lock_mut().push_back(item);
	}

	pub async fn pop(&self) -> T {
		loop {
			let notify = {
				let queue = self.state.lock();
				if !queue.is_empty() {
					return queue.into_mut().pop_front().unwrap();
				}
				queue.changed()
			};

			notify.await
		}
	}
}