async_nursery 0.6.0

Primitive for structured concurrency
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

// Tested:
//
// ✔ pass nursery to function as reference
// ✔ pass nursery to function as clone
// ✔ pass nursery to spawned subtasks as clone
//
#![ cfg( target_arch = "wasm32" ) ]

mod common;
use common::import   ::*;
use wasm_bindgen_test::*;

wasm_bindgen_test_configure!( run_in_browser );



#[ wasm_bindgen_test ]
//
async fn spawn()
{
	let (nursery, output) = Nursery::new( Bindgen );

	nursery.nurse( async { 5 + 5 } ).unwrap();
	nursery.nurse( async { 5 + 5 } ).unwrap();

	drop(nursery);

	let sum = output.fold( 0, |acc, x| async move { acc + x } ).await;

	assert_eq!( 20, sum );
}