Source code
Revision control
Copy as Markdown
Other Tools
// Licensed under the Apache License, Version 2.0 <LICENSE-APACHE or
// option. This file may not be copied, modified, or distributed
// except according to those terms.
use neqo_transport::streams::SendGroupId;
/// Mints connection-unique send-group [`SendGroupId`]s. Owned by the connection rather than a
/// global, so uniqueness holds within a connection no matter which thread it runs on.
#[derive(Debug, Default)]
pub struct Generator(u64);
impl Generator {
/// Mint the next send-group [`SendGroupId`]. IDs start at 1; 0 is reserved as a sentinel.
///
/// # Panics
///
/// Panics if the counter overflows `u64::MAX`.
pub const fn next_id(&mut self) -> SendGroupId {
let id = self.0.checked_add(1).expect("SendGroup ID overflow");
self.0 = id;
SendGroupId::new(id)
}
}