Function drive_pending_syncs 

pub async fn drive_pending_syncs<T>(
    pending: &PendingSyncs,
    fut: impl Future<Output = T>,
) -> T

Drive fut to completion, releasing any parked syncs each time it stalls.