tea-codec 0.2.0-dev.1

The TEA SDK
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

use lazy_static::lazy_static;
use std::sync::Arc;

use std::future::Future;
use tokio::{
	runtime::{Builder, EnterGuard, Runtime},
	task::JoinHandle,
};

lazy_static! {
	static ref RUNTIME: Arc<Runtime> = Arc::new(
		Builder::new_multi_thread()
			.enable_all()
			.worker_threads(4)
			// .max_blocking_threads(usize::MAX)
			.build()
			.unwrap()
	);
}

pub fn block_on<T>(f: T) -> T::Output
where
	T: Future,
{
	RUNTIME.block_on(f)
}

pub fn spawn<T>(f: T) -> JoinHandle<T::Output>
where
	T: Future + Send + 'static,
	T::Output: Send + 'static,
{
	RUNTIME.spawn(f)
}

pub fn spawn_blocking<F, R>(f: F) -> JoinHandle<R>
where
	F: FnOnce() -> R + Send + 'static,
	R: Send + 'static,
{
	RUNTIME.spawn_blocking(f)
}

pub fn enter() -> EnterGuard<'static> {
	RUNTIME.enter()
}