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

// Tested:
//
// ✔ Use send and verify the actor has processed the message.
// ✔ Use call and verify the actor has processed the message.
// ✔ Use send from several addresses and verify the actor has processed the message.
// ✔ Use call from several addresses and verify the actor has processed the message.
//
#![ cfg(not( target_arch = "wasm32" )) ]


mod common;

use
{
	common          :: { import::*, actors::* } ,
	async_executors :: { AsyncStd             } ,
};



#[async_std::test]
//
async fn basic_send() -> Result<(), DynError >
{
	let mut addr = Addr::builder( "basic_send" ).spawn( Sum(5), &AsyncStd )?;

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

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

	Ok(())
}



#[async_std::test]
//
async fn basic_call() -> Result<(), DynError >
{
	let mut addr = Addr::builder( "basic_call" ).spawn( Sum(5), &AsyncStd )?;

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

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

	Ok(())
}



#[async_std::test]
//
async fn send_from_multiple_addrs() -> Result<(), DynError >
{
	let mut addr  = Addr::builder( "send_from_multiple_addrs").spawn( Sum(5), &AsyncStd )?;
	let mut addr2 = addr.clone();

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

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

	Ok(())
}



#[async_std::test]
//
async fn call_from_multiple_addrs() -> Result<(), DynError >
{
	let mut addr  = Addr::builder( "call_from_multiple_addrs" ).spawn( Sum(5), &AsyncStd )?;
	let mut addr2 = addr.clone();

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

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

	Ok(())
}