Struct FlightLeader 

pub struct FlightLeader { /* private fields */ }

Handle for the leader task that will execute the query and broadcast results.

If the leader is dropped without calling complete() (e.g., the task panics), the Drop impl removes the key from the in-flight map so new requests don’t join a dead channel. Followers on the dead channel receive a RecvError from the broadcast receiver, which surfaces as a query error.

Implementations

impl FlightLeader

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

Broadcast 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.