naja_async_runtime 0.3.4

A lightweight universal runtime for futures.
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

#![ cfg(not( target_arch = "wasm32" )) ]

// Tested:
//
// - ✔ shut down local pool before spawning does not generate error.
// - ✔ double executor init error: Local - Local.
// - ✔ double executor init error: Local - Pool.
// - ✔ double executor init error: Pool  - Local.


use
{
	async_runtime :: { *             } ,
	futures       :: { future::ready } ,
};




// This is an attempt to trigger the shutdown error on the localpool from the futures lib, but run does not
// shut it down, so I don't know how to trigger this error.
//
#[test]
//
fn shutdown()
{
	rt::init( RtConfig::Local ).expect( "no double executor init" );
	rt::run();

	let result = rt::spawn( ready(()) );

	assert!( result.is_ok() );

	rt::run();
}



// Trigger DoubleExecutorInit.
//
#[test]
//
fn double_init()
{
	             rt::init( RtConfig::Local ).expect( "no double executor init" );
	let result = rt::init( RtConfig::Local );

	assert_eq!( &RtErrKind::DoubleExecutorInit, result.unwrap_err().kind() );
}



// Trigger DoubleExecutorInit with 2 different executors.
//
#[test]
//
fn double_init_different()
{
	             rt::init( RtConfig::Local ).expect( "no double executor init" );
	let result = rt::init( RtConfig::Pool  );

	assert_eq!( &RtErrKind::DoubleExecutorInit, result.unwrap_err().kind() );
}



// Trigger DoubleExecutorInit with 2 different executors.
//
#[test]
//
fn double_init_inverse()
{
	             rt::init( RtConfig::Pool  ).expect( "no double executor init" );
	let result = rt::init( RtConfig::Local );

	assert_eq!( &RtErrKind::DoubleExecutorInit, result.unwrap_err().kind() );
}