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

use std::pin::Pin;

use async_trait::async_trait;
use futures::Future;

use crate::{traits::FrameProcessor};

pub type PinnedFrameData<F> = Pin<Box<dyn Future<Output = Option<F>> + Send>>;
type AsyncProcessorFn<F> = fn(F) -> PinnedFrameData<F>;

pub struct AsyncFunction<F> {
    function: AsyncProcessorFn<F>
}

impl<F> AsyncFunction<F> {
    pub fn new(function: AsyncProcessorFn<F>) -> Self {
        Self {
            function,
        }
    }
}

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

#[macro_export]
macro_rules! async_func {
    (async move $body:block) => {
        Box::pin(async move { $body })
    };
}