drain_pending

Function drain_pending 

Source
fn drain_pending(db: &Db, rx: &mut EventLogRx)
Expand description

Best-effort drain of in-flight entries on shutdown. Skips send().await because we’re past the cancellation point — no new entries can arrive (every applier holds a Sender that’s already been dropped or is about to be).