Function park_queued 

pub(super) fn park_queued(
    queued_tx: Option<Sender<Result<(), Error>>>,
    waiters: &mut Vec<Sender<Result<(), Error>>>,
)

Parks the optional queue-acknowledgement channel until the next successful persist, so queued() reflects real durability.