amadeus 0.4.3

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

use futures::FutureExt;
use std::{panic, panic::AssertUnwindSafe, time::SystemTime};

use amadeus::prelude::*;

#[tokio::test(threaded_scheduler)]
#[cfg_attr(miri, ignore)]
async fn panic() {
	let start = SystemTime::now();

	let pool = &ThreadPool::new(None, None).unwrap();

	let res = AssertUnwindSafe((0i32..1_000).into_par_stream().for_each(pool, |i| {
		if i == 500 {
			panic!("this is intended to panic")
		}
	}))
	.catch_unwind()
	.await;

	assert!(res.is_err());

	println!("in {:?}", start.elapsed().unwrap());
}