pub struct CoroRun<T, E> { /* private fields */ }
Available on crate features
unsafe_async
and alloc
only.Expand description
A managed dynamic collection of single-thread Coro
utines.
It maintains a queue of coroutines in the stack, and runs them in a loop until they are all complete.
When a coroutine is polled and returns TaskPoll::Pending
, it is put back
into the queue to be run again later. If it returns TaskPoll::Ready
it is considered complete and is not put back into the queue.
§Examples
// devela::examples::work::coro_run
//!
use devela::{serr, sok, CoroRun};
fn main() {
let mut cr = CoroRun::<char, String>::new();
for i in 1..=3 {
cr.push(|mut c| async move {
println!("> instance {i} NEW");
let mut count = 0;
loop {
let res = c.yield_ok('a').await?;
println!(" instance {i} A.{count} {res:?})");
let _res = c.yield_ok('b').await?;
println!(" instance {i} B {_res:?}");
if count > 2 {
break;
}
count += 1;
}
println!(" instance {i} BYE!");
if i == 2 {
serr(format!["instance {i} produced an error"])
} else {
sok('x')
}
});
}
cr.push(|mut c| async move {
println!("> instance 4 NEW");
for _n in 0..3 {
let _res = c.yield_err(format!["custom err"]).await?;
}
println!(" instance 4 BYE!");
None
});
println!("Running");
cr.run();
println!("Done");
}
It outputs:
Running
> instance 1 NEW
> instance 2 NEW
> instance 3 NEW
> instance 4 NEW
instance 1 A.0 Ok('a'))
instance 2 A.0 Ok('a'))
instance 3 A.0 Ok('a'))
instance 1 B Ok('b')
instance 2 B Ok('b')
instance 3 B Ok('b')
instance 1 A.1 Ok('a'))
instance 2 A.1 Ok('a'))
instance 3 A.1 Ok('a'))
instance 4 BYE!
instance 1 B Ok('b')
instance 2 B Ok('b')
instance 3 B Ok('b')
instance 1 A.2 Ok('a'))
instance 2 A.2 Ok('a'))
instance 3 A.2 Ok('a'))
instance 1 B Ok('b')
instance 2 B Ok('b')
instance 3 B Ok('b')
instance 1 A.3 Ok('a'))
instance 2 A.3 Ok('a'))
instance 3 A.3 Ok('a'))
instance 1 B Ok('b')
instance 2 B Ok('b')
instance 3 B Ok('b')
Done
Implementations§
Trait Implementations§
Auto Trait Implementations§
impl<T, E> Freeze for CoroRun<T, E>
impl<T, E> !RefUnwindSafe for CoroRun<T, E>
impl<T, E> !Send for CoroRun<T, E>
impl<T, E> !Sync for CoroRun<T, E>
impl<T, E> Unpin for CoroRun<T, E>
impl<T, E> !UnwindSafe for CoroRun<T, E>
Blanket Implementations§
§impl<T> ArchivePointee for T
impl<T> ArchivePointee for T
§type ArchivedMetadata = ()
type ArchivedMetadata = ()
The archived version of the pointer metadata for this type.
§fn pointer_metadata(
_: &<T as ArchivePointee>::ArchivedMetadata,
) -> <T as Pointee>::Metadata
fn pointer_metadata( _: &<T as ArchivePointee>::ArchivedMetadata, ) -> <T as Pointee>::Metadata
Converts some archived metadata to the pointer metadata for itself.
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> ByteSized for T
impl<T> ByteSized for T
Source§const BYTE_ALIGN: usize = _
const BYTE_ALIGN: usize = _
The alignment of this type in bytes.
Source§fn byte_align(&self) -> usize ⓘ
fn byte_align(&self) -> usize ⓘ
Returns the alignment of this type in bytes.
Source§fn ptr_size_ratio(&self) -> [usize; 2]
fn ptr_size_ratio(&self) -> [usize; 2]
Source§impl<T, R> Chain<R> for Twhere
T: ?Sized,
impl<T, R> Chain<R> for Twhere
T: ?Sized,
Source§impl<T> ExtAny for T
impl<T> ExtAny for T
Source§fn as_any_mut(&mut self) -> &mut dyn Anywhere
Self: Sized,
fn as_any_mut(&mut self) -> &mut dyn Anywhere
Self: Sized,
Source§impl<T> ExtMem for Twhere
T: ?Sized,
impl<T> ExtMem for Twhere
T: ?Sized,
Source§const NEEDS_DROP: bool = _
const NEEDS_DROP: bool = _
Know whether dropping values of this type matters, in compile-time.
Source§fn mem_align_of_val(&self) -> usize ⓘ
fn mem_align_of_val(&self) -> usize ⓘ
Returns the alignment of the pointed-to value in bytes. Read more
Source§fn mem_size_of_val(&self) -> usize ⓘ
fn mem_size_of_val(&self) -> usize ⓘ
Returns the size of the pointed-to value in bytes. Read more
Source§fn mem_needs_drop(&self) -> bool
fn mem_needs_drop(&self) -> bool
Returns
true
if dropping values of this type matters. Read moreSource§fn mem_forget(self)where
Self: Sized,
fn mem_forget(self)where
Self: Sized,
Forgets about
self
without running its destructor. Read moreSource§fn mem_replace(&mut self, other: Self) -> Selfwhere
Self: Sized,
fn mem_replace(&mut self, other: Self) -> Selfwhere
Self: Sized,
Source§unsafe fn mem_zeroed<T>() -> T
unsafe fn mem_zeroed<T>() -> T
Available on crate feature
unsafe_layout
only.Returns the value of type
T
represented by the all-zero byte-pattern. Read moreSource§unsafe fn mem_transmute_copy<Src, Dst>(src: &Src) -> Dst
unsafe fn mem_transmute_copy<Src, Dst>(src: &Src) -> Dst
Available on crate feature
unsafe_layout
only.Returns the value of type
T
represented by the all-zero byte-pattern. Read moreSource§fn mem_as_bytes(&self) -> &[u8] ⓘ
fn mem_as_bytes(&self) -> &[u8] ⓘ
Available on crate feature
unsafe_slice
only.§impl<S> FromSample<S> for S
impl<S> FromSample<S> for S
fn from_sample_(s: S) -> S
Source§impl<T> Hook for T
impl<T> Hook for T
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
§fn in_current_span(self) -> Instrumented<Self> ⓘ
fn in_current_span(self) -> Instrumented<Self> ⓘ
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
Converts
self
into a Left
variant of Either<Self, Self>
if into_left
is true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
Converts
self
into a Left
variant of Either<Self, Self>
if into_left(&self)
returns true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read more§impl<F, T> IntoSample<T> for Fwhere
T: FromSample<F>,
impl<F, T> IntoSample<T> for Fwhere
T: FromSample<F>,
fn into_sample(self) -> T
§impl<T> LayoutRaw for T
impl<T> LayoutRaw for T
§fn layout_raw(_: <T as Pointee>::Metadata) -> Result<Layout, LayoutError> ⓘ
fn layout_raw(_: <T as Pointee>::Metadata) -> Result<Layout, LayoutError> ⓘ
Returns the layout of the type.
§impl<T, N1, N2> Niching<NichedOption<T, N1>> for N2
impl<T, N1, N2> Niching<NichedOption<T, N1>> for N2
§unsafe fn is_niched(niched: *const NichedOption<T, N1>) -> bool
unsafe fn is_niched(niched: *const NichedOption<T, N1>) -> bool
Returns whether the given value has been niched. Read more
§fn resolve_niched(out: Place<NichedOption<T, N1>>)
fn resolve_niched(out: Place<NichedOption<T, N1>>)
Writes data to
out
indicating that a T
is niched.