trellis-rs 0.10.2

Curated public Rust facade for Trellis clients and services.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29

use bytes::Bytes;

use super::{EventDescriptor, ServerError};

/// A thin descriptor-backed event publisher over NATS.
#[derive(Debug, Clone)]
pub struct EventPublisher {
    client: async_nats::Client,
}

impl EventPublisher {
    /// Wrap an existing NATS client.
    pub fn new(client: async_nats::Client) -> Self {
        Self { client }
    }

    /// Publish one descriptor-backed event.
    pub async fn publish<D>(&self, event: &D::Event) -> Result<(), ServerError>
    where
        D: EventDescriptor,
    {
        let payload = Bytes::from(serde_json::to_vec(event)?);
        self.client
            .publish(D::SUBJECT.to_string(), payload)
            .await
            .map_err(|error| ServerError::Nats(error.to_string()))?;
        Ok(())
    }
}