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
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55

use
{
	crate           :: { Nurse, LocalNurse, NurseErr, import::* } ,
	tracing_futures :: { Instrument, Instrumented, WithDispatch } ,
	futures         :: { FutureExt                              } ,
};



impl<T, Out> Nurse<Out> for Instrumented<T> where T: Nurse<Out>, Out: 'static + Send
{
	fn nurse_obj( &self, future: FutureObj<'static, Out> ) -> Result<(), NurseErr>
	{
		let fut = future.instrument( self.span().clone() );

		self.inner().nurse_obj( FutureObj::new(fut.boxed()) )
	}
}



impl<T, Out> Nurse<Out> for WithDispatch<T> where T: Nurse<Out>, Out: 'static + Send
{
	fn nurse_obj( &self, future: FutureObj<'static, Out> ) -> Result<(), NurseErr>
	{
		let fut = self.with_dispatch( future );

		self.inner().nurse_obj( FutureObj::new(fut.boxed()) )
	}
}



impl<T, Out> LocalNurse<Out> for Instrumented<T> where T: LocalNurse<Out>, Out: 'static
{
	fn nurse_local_obj( &self, future: LocalFutureObj<'static, Out> ) -> Result<(), NurseErr>
	{
		let fut = future.instrument( self.span().clone() );

		self.inner().nurse_local_obj( LocalFutureObj::new(fut.boxed_local()) )
	}
}




impl<T, Out> LocalNurse<Out> for WithDispatch<T> where T: LocalNurse<Out>, Out: 'static
{
	fn nurse_local_obj( &self, future: LocalFutureObj<'static, Out> ) -> Result<(), NurseErr>
	{
		let fut = self.with_dispatch(future);

		self.inner().nurse_local_obj( LocalFutureObj::new(fut.boxed_local()) )
	}
}