Struct integra8_scheduling::TaskScheduler
source · [−]pub struct TaskScheduler<Stream> { /* private fields */ }
Implementations
sourceimpl<Stream: TaskStream> TaskScheduler<Stream>
impl<Stream: TaskStream> TaskScheduler<Stream>
pub fn new(state_machine: Stream, max_concurrency_limit: usize) -> Self
pub async fn for_each_concurrent<InvokeFn, Fut>(self, invoke: InvokeFn) where
InvokeFn: Fn(<Stream as TaskStream>::Payload) -> Fut + Copy,
Fut: Future<Output = ()>,
pub fn queue_length(&self) -> usize
Auto Trait Implementations
impl<Stream> !RefUnwindSafe for TaskScheduler<Stream>
impl<Stream> Send for TaskScheduler<Stream> where
Stream: Send,
impl<Stream> !Sync for TaskScheduler<Stream>
impl<Stream> Unpin for TaskScheduler<Stream> where
Stream: Unpin,
impl<Stream> !UnwindSafe for TaskScheduler<Stream>
Blanket Implementations
sourceimpl<T> BorrowMut<T> for T where
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more