bevy_persistence_database 0.2.7

A persistence and database integration solution for the Bevy game engine
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

use bevy::prelude::{Resource, World};
use std::sync::Mutex;

/// Thread-safe queue of world mutations to be applied later in the frame.
#[derive(Resource, Default)]
pub(crate) struct DeferredWorldOperations {
    queue: Mutex<Vec<Box<dyn FnOnce(&mut World) + Send>>>,
}

impl DeferredWorldOperations {
    pub fn push(&self, op: Box<dyn FnOnce(&mut World) + Send>) {
        self.queue.lock().unwrap().push(op);
    }

    /// Drain and return all pending world operations.
    pub fn drain(&self) -> Vec<Box<dyn FnOnce(&mut World) + Send>> {
        let mut guard = self.queue.lock().unwrap();
        let mut out = Vec::new();
        std::mem::swap(&mut *guard, &mut out);
        out
    }
}