mequeue 0.0.1

mequeue
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

use {crate::worker::MappedWorker, async_channel::Receiver};

pub type Wal<T1> = std::sync::Arc<parking_lot::Mutex<std::option::Option<T1>>>;

pub async fn dispatch<E1: Clone, W1>(wal: Wal<E1>, receiver: Receiver<E1>, worker: W1)
where
	W1: MappedWorker<E1>,
{
	let maybe = { wal.lock().clone() };

	if let Some(event) = maybe {
		// Try to handle last not properly handled value

		worker.execute(event.clone()).await;

		wal.lock().take();
	}

	let update = |event: E1| {
		let mut wal = wal.lock();

		*wal = Some(event);
	};

	while let Ok(event) = receiver.recv().await {
		// Keep event in state to ensure cancel safety

		(update(event.clone()), worker.execute(event).await);

		wal.lock().take();
	}
}