esrc 0.1.0

Primitives for implementing event sourcing and CQRS systems
Documentation 
1
2
3
4
5
6
7
8
9
10
11

use async_nats::{HeaderValue, Message};

pub const VERSION_KEY: &str = "Esrc-Version";

pub fn get<'a>(message: &'a Message, key: &str) -> Option<&'a str> {
    message
        .headers
        .as_ref()
        .and_then(|headers| headers.get(key))
        .map(HeaderValue::as_str)
}