vorma 0.86.0-pre.3

Vorma 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
45
46
47
48
49
50

use std::future::Future;
use std::pin::Pin;
use std::sync::Arc;

use super::error::InputError;
use super::request::RawRequest;

type InputParseFuture<'a, I> = Pin<Box<dyn Future<Output = Result<I, InputError>> + Send + 'a>>;
type InputParseFn<I> = dyn for<'a> Fn(&'a RawRequest) -> InputParseFuture<'a, I> + Send + Sync;

pub struct InputParser<I> {
	parse: Arc<InputParseFn<I>>,
}

impl<I> Clone for InputParser<I> {
	fn clone(&self) -> Self {
		Self {
			parse: self.parse.clone(),
		}
	}
}

impl<I> InputParser<I>
where
	I: Send + 'static,
{
	#[cfg(test)]
	pub fn callback(
		parse: impl Fn(&RawRequest) -> Result<I, InputError> + Send + Sync + 'static,
	) -> Self {
		Self {
			parse: Arc::new(move |request| Box::pin(std::future::ready(parse(request)))),
		}
	}

	pub(crate) fn parse<'a>(&self, request: &'a RawRequest) -> InputParseFuture<'a, I> {
		(self.parse)(request)
	}
}

impl<I> InputParser<I>
where
	I: Default + Send + Sync + 'static,
{
	pub fn default_input() -> Self {
		Self {
			parse: Arc::new(|_| Box::pin(std::future::ready(Ok(I::default())))),
		}
	}
}