amadeus 0.1.6

Harmonious distributed data processing & analysis in Rust. parquet postgres aws s3 cloudfront elb json csv logs hadoop hdfs arrow common crawl
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

use std::panic;

use super::util::Panicked;

#[derive(Copy, Clone, Default, Debug)]
pub struct LocalPool(());
impl LocalPool {
	pub fn new() -> Self {
		LocalPool(())
	}
	pub fn spawn<F: FnOnce() -> T, T>(
		&self, work: F,
	) -> impl std::future::Future<Output = Result<T, Panicked>> {
		let _self = self;
		let ret = panic::catch_unwind(panic::AssertUnwindSafe(work));
		let ret = ret.map_err(Panicked::from);
		futures::future::ready(ret)
	}
}