haematite 0.6.1

Content-addressed, branchable, actor-native storage engine
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

use std::cell::Cell;

use wasm_bindgen::JsValue;
use wasm_bindgen_futures::JsFuture;

use super::BrowserLocalError;
use super::js::{haem_release_owner, haem_release_owner_now};

pub(super) struct OwnerLock {
    handle: JsValue,
    released: Cell<bool>,
}

impl OwnerLock {
    pub(super) const fn new(handle: JsValue) -> Self {
        Self {
            handle,
            released: Cell::new(false),
        }
    }

    pub(super) async fn release(&self) -> Result<(), BrowserLocalError> {
        if self.released.replace(true) {
            return Ok(());
        }
        JsFuture::from(haem_release_owner(&self.handle))
            .await
            .map_err(|_| BrowserLocalError::WorkerClosed)?;
        Ok(())
    }
}

impl Drop for OwnerLock {
    fn drop(&mut self) {
        if !self.released.replace(true) {
            haem_release_owner_now(&self.handle);
        }
    }
}