Struct Supervisor 

pub struct Supervisor { /* private fields */ }

Mounts devices as they arrive and unmounts them as they leave.

Implementations

impl Supervisor

pub fn new( config: SupervisorConfig, source: Arc<dyn DeviceSource>, rt: Handle, commands: Sender<Command>, ) -> Self

Build a supervisor. commands must be a sender for the same channel whose receiver goes to Supervisor::run.

pub fn run(self, commands: Receiver<Command>)

Handle commands until Command::Stop arrives or every sender is dropped, then unmount everything.

Blocks the calling thread. See the module docs on why it can’t run inside a tokio runtime.

pub fn mounted_keys(&self) -> Vec<String>

Devices currently mounted, by key. Used by tests.