Struct FlightLeader 

pub struct FlightLeader { /* private fields */ }

Handle for the leader thread that will execute the query and notify followers.

If the leader is dropped without calling complete() (e.g., the thread panics), the Drop impl removes the key from the in-flight map so new requests don’t wait on a dead condvar. Followers waiting on the condvar are woken and will find None in the result, which surfaces as a query error.

Implementations

impl FlightLeader

pub fn complete( self, sf: &Singleflight, result: Arc<Result<Arc<OwnedResultSnapshot>, BsqlError>>, )

Send the result to all waiting followers and remove from in-flight map.

Trait Implementations

impl Drop for FlightLeader

fn drop(&mut self)

Executes the destructor for this type.