pub struct Manager { /* private fields */ }Expand description
System for managing data track subscriptions.
Implementations§
Source§impl Manager
impl Manager
Sourcepub fn new(
options: ManagerOptions,
) -> (Self, ManagerInput, impl Stream<Item = OutputEvent>)
pub fn new( options: ManagerOptions, ) -> (Self, ManagerInput, impl Stream<Item = OutputEvent>)
Creates a new manager.
Returns a tuple containing the following:
- The manager itself to be spawned by the caller (see
Manager::run). - Channel for sending
InputEvents to be processed by the manager. - Stream for receiving
OutputEvents produced by the manager.
Sourcepub async fn run(self)
pub async fn run(self)
Run the manager task, consuming self.
The manager will continue running until receiving InputEvent::Shutdown.
Auto Trait Implementations§
impl Freeze for Manager
impl !RefUnwindSafe for Manager
impl Send for Manager
impl Sync for Manager
impl Unpin for Manager
impl UnsafeUnpin for Manager
impl !UnwindSafe for Manager
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