yazi-shared 26.5.6

Yazi shared library
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

use std::sync::Arc;

use parking_lot::Mutex;
use tokio::sync::Notify;

#[derive(Clone, Debug, Default)]
pub struct LastValue<T> {
	inner: Arc<(Notify, Mutex<Option<T>>)>,
}

impl<T> LastValue<T> {
	pub fn set(&self, data: T) {
		*self.inner.1.lock() = Some(data);
		self.inner.0.notify_waiters();
	}

	pub async fn get(&self) -> T {
		loop {
			let notified = self.inner.0.notified();
			if let Some(data) = self.inner.1.lock().take() {
				return data;
			}

			notified.await;
		}
	}
}