spacegate-kernel 0.2.0-alpha.4

A library-first, lightweight, high-performance, cloud-native supported API gateway
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

use std::{
    fmt::Debug,
    sync::{Arc, Mutex},
};

use crate::SgRequest;

/// It's a hole, don't abuse it pls.
#[derive(Clone, Default)]
pub struct Defer {
    mappers: Arc<Mutex<Vec<Box<dyn FnOnce(SgRequest) -> SgRequest + Send>>>>,
}

impl Debug for Defer {
    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
        f.debug_struct("Defer").finish()
    }
}

impl Defer {
    pub fn push_back(&self, f: impl FnOnce(SgRequest) -> SgRequest + Send + 'static) {
        let mut g = self.mappers.lock().expect("never poisoned");
        g.push(Box::new(f))
    }
    pub fn apply(&self, req: SgRequest) -> SgRequest {
        let mut g = self.mappers.lock().expect("never poisoned");
        let mut req = req;
        for f in g.drain(..) {
            req = (f)(req)
        }
        req
    }
}