Struct IsleDrivers 

pub struct IsleDrivers { /* private fields */ }

The lifecycle owners of the connection threads a session’s log lives on.

rusqlite_isle::AsyncIsle hands back a cloneable handle and a driver that is not clonable: the driver owns the thread’s join handle and is the only thing that can drain and stop it. A session cannot hold its own — the whole point of the drop backstop is that a handle nobody closed can still hand its session_closed to the isle after the handle is gone, and a thread its own store had already stopped could not take it.

So the drivers are parked here instead: one collection per host run, shut down once at the end of it, exactly as the std.ts connection thread is. Cheap to clone (an Arc), because every site that opens a store needs to reach it.

The lock is a plain Mutex and is never held across an .await: IsleDrivers::shutdown takes the whole list out under the lock and releases it before it starts waiting on the first thread.

Implementations

impl IsleDrivers

pub fn new() -> Self

A fresh, empty collection.

pub fn len(&self) -> usize

How many connection threads are still owned here.

pub fn is_empty(&self) -> bool

Whether no connection thread has been opened (or all were drained).

pub async fn shutdown(&self) -> Vec<IsleError>

Drain every thread: queued jobs run to completion, then each thread stops and is joined.

The queued jobs matter — the drop backstop submits its session_closed without waiting for it, so this is where those land. Failures are collected rather than raised on the first one: a thread that panicked is no reason to leave the rest running.

Idempotent: a second call finds nothing parked and returns an empty list.

Trait Implementations

impl Clone for IsleDrivers

fn clone(&self) -> IsleDrivers

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for IsleDrivers

fn fmt(&self, f: &mut Formatter<'_>) -> Result

The drivers themselves have nothing worth printing; the count is what a caller debugging a leak wants.

impl Default for IsleDrivers

fn default() -> IsleDrivers

Returns the “default value” for a type.