nstreams-core 0.3.0

Generic versioned event stream handler with history replay
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

/// Client subscription identifier prefix.
pub const REQUEST_ID_PREFIX: &str = "ns-";

/// Generate a new subscription request id (`ns-` + 32 hex chars).
pub fn new_request_id() -> String {
    format!("{REQUEST_ID_PREFIX}{}", uuid::Uuid::new_v4().simple())
}

#[cfg(test)]
mod tests {
    use super::*;

    #[test]
    fn request_id_has_expected_shape() {
        let id = new_request_id();
        assert!(id.starts_with(REQUEST_ID_PREFIX));
        assert_eq!(id.len(), REQUEST_ID_PREFIX.len() + 32);
    }
}