remotia-core 0.1.2

Core components of remotia, an open source framework for the development of remote rendering software in pure Rust
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
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67

use std::marker::PhantomData;

use async_trait::async_trait;

use crate::{pipeline::component::Component, traits::FrameProcessor};

pub struct Function<F> {
    function: fn(F) -> Option<F>,
}

impl<F> Function<F> {
    pub fn new(function: fn(F) -> Option<F>) -> Self {
        Self { function }
    }
}

#[async_trait]
impl<F: Send> FrameProcessor<F> for Function<F> {
    async fn process(&mut self, frame_data: F) -> Option<F> {
        (self.function)(frame_data)
    }
}

pub struct Closure<FD, FN>
where
    FN: Fn(FD) -> Option<FD>,
{
    function: FN,
    data_type: PhantomData<FD>,
}

impl<FD, FN> Closure<FD, FN>
where
    FN: Fn(FD) -> Option<FD>,
{
    pub fn new(function: FN) -> Self {
        Self {
            function,
            data_type: PhantomData,
        }
    }
}

#[async_trait]
impl<FD, FN> FrameProcessor<FD> for Closure<FD, FN>
where
    FD: Send,
    FN: Fn(FD) -> Option<FD> + Send,
{
    async fn process(&mut self, frame_data: FD) -> Option<FD> {
        (self.function)(frame_data)
    }
}

pub trait ClosureAppends<FN> {
    fn closure(self, closure: FN) -> Self;
}

impl<FD, FN> ClosureAppends<FN> for Component<FD>
where
    FD: Default + Send + 'static,
    FN: Fn(FD) -> Option<FD> + Send + 'static,
{
    fn closure(self, closure: FN) -> Self {
        self.append(Closure::new(closure))
    }
}