npsd 0.2.0

Network payload serializer / deserializer framework
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


use std::sync::Arc;
use crossbeam::queue::SegQueue;

use crate::AnyBox;

#[derive(Clone, Debug)]
pub struct Stack<'a> {
    stack: Arc<SegQueue<Box<dyn AnyBox<'a> + 'a>>>,
}

impl<'a> Stack<'a> {
    pub fn new() -> Self {
        Self {
            stack: Arc::new(SegQueue::new()),
        }
    }
}

impl<'a> Stack<'a> {
    pub fn push<T: AnyBox<'a>>(&mut self, value: Box<T>) -> &'a T {
        let reference: &'a T = unsafe { &*(value.as_ref() as *const T) };
        self.stack.push(value);
        reference
    }

    pub fn push_mut<T: AnyBox<'a>>(&mut self, mut value: Box<T>) -> &'a mut T {
        let reference: &'a mut T = unsafe { &mut *(value.as_mut() as *mut T) };
        self.stack.push(value);
        reference
    }

    pub fn push_array<T: AnyBox<'a>>(&mut self, values: Box<[T]>) -> &'a [T] {
        let reference: &'a [T] = unsafe { &*(values.as_ref() as *const [T]) };
        self.stack.push(Box::new(values));
        reference
    }

    pub fn push_array_mut<T: AnyBox<'a>>(&mut self, mut values: Box<[T]>) -> &'a mut [T] {
        let reference: &'a mut [T] = unsafe { &mut *(values.as_mut() as *mut [T]) };
        self.stack.push(Box::new(values));
        reference
    }
}