thespis_impl 0.3.0

Reference implementation for the thespis actor model
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
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99

// Tested:
//
// ✔ Basic send
// ✔ Basic call
// ✔ Send from multiple addresses
// ✔ Call from multiple addresses
// ✔ Stop when addresses dropped before starting the mb.
//
#![ cfg( target_arch = "wasm32" ) ]

wasm_bindgen_test_configure!( run_in_browser );

mod common;

use
{
	common            :: { import::*, actors::* } ,
	async_executors   :: { Bindgen              } ,
	wasm_bindgen_test :: { *                    } ,
	wasm_bindgen      :: { *                    } ,

};


#[ wasm_bindgen_test ]
//
async fn stop_when_addresses_dropped_before_start_mb()
{
	// let _ = flexi_logger::Logger::with_str( "trace" ).start();

	let (addr, mb) = Addr::builder( "stop_when_addresses_dropped_before_start_mb" ).build();

	let addr2 = addr.clone();

	drop( addr  );
	drop( addr2 );

	let mb_handle = Bindgen.spawn_handle( mb.start( Sum(5) ) ).unwrap_throw();

	// the handle will resolve when the mailbox has ended. If not this test will hang.
	//
	mb_handle.await;
}



#[ wasm_bindgen_test ]
//
async fn basic_send()
{
	let mut addr = Addr::builder( "basic_send" ).spawn( Sum(5), &Bindgen ).unwrap_throw();

	addr.send( Add( 10 ) ).await.unwrap_throw();

	assert_eq!( 15, addr.call( Show ).await.unwrap_throw() );
}



#[ wasm_bindgen_test ]
//
async fn basic_call()
{
	let mut addr = Addr::builder( "basic_call" ).spawn( Sum(5), &Bindgen ).unwrap_throw();

	addr.call( Add(10) ).await.unwrap_throw();

	assert_eq!( 15, addr.call( Show ).await.unwrap_throw() );
}



#[ wasm_bindgen_test ]
//
async fn send_from_multiple_addrs()
{
	let mut addr  = Addr::builder( "send_from_multiple_addrs" ).spawn( Sum(5), &Bindgen ).unwrap_throw();
	let mut addr2 = addr.clone();

	addr .send( Add( 10 ) ).await.unwrap_throw();
	addr2.send( Add( 10 ) ).await.unwrap_throw();

	assert_eq!( 25, addr.call( Show{} ).await.unwrap_throw() );
}



#[ wasm_bindgen_test ]
//
async fn call_from_multiple_addrs()
{
	let mut addr  = Addr::builder( "call_from_multiple_addrs" ).spawn( Sum(5), &Bindgen ).unwrap_throw();
	let mut addr2 = addr.clone();

	addr .call( Add( 10 ) ).await.unwrap_throw();
	addr2.call( Add( 10 ) ).await.unwrap_throw();

	assert_eq!( 25, addr.call ( Show{} ).await.unwrap_throw() );
}