pub struct ProcessPool { /* private fields */ }Implementations§
Source§impl ProcessPool
impl ProcessPool
pub fn new(stream_tx: Sender<StreamItem>) -> Self
pub fn reconcile( &mut self, desired: Vec<ProcessSource>, ) -> ReconcileErrors<ProcessIdentity, SpawnError>
pub fn get(&self, identity: &ProcessIdentity) -> Option<&ProcessState>
pub fn iter(&self) -> impl Iterator<Item = (&ProcessIdentity, &ProcessState)>
Trait Implementations§
Source§impl Drop for ProcessPool
impl Drop for ProcessPool
Auto Trait Implementations§
impl Freeze for ProcessPool
impl RefUnwindSafe for ProcessPool
impl Send for ProcessPool
impl Sync for ProcessPool
impl Unpin for ProcessPool
impl UnsafeUnpin for ProcessPool
impl UnwindSafe for ProcessPool
Blanket Implementations§
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