distributed 4.3.0

CQRS/ES framework for Rust using Plain Old Rust Structs — append-only events, replay, snapshots, outbox, service bus, and pluggable infrastructure
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
30
31
32
33
34
35

//! Local dispatcher adapter over an in-process [`Service`].

use super::{CommandDispatchError, CommandDispatcher};
use crate::microsvc::{CommandRequest, CommandResponse, Service};
use async_trait::async_trait;
use std::sync::Arc;

/// Dispatches commands to a local executable [`Service`].
pub struct LocalCommandDispatcher {
    service: Arc<Service>,
}

impl LocalCommandDispatcher {
    pub fn new(service: Arc<Service>) -> Self {
        Self { service }
    }

    pub fn service(&self) -> &Arc<Service> {
        &self.service
    }
}

#[async_trait]
impl CommandDispatcher for LocalCommandDispatcher {
    async fn dispatch(
        &self,
        request: &CommandRequest,
    ) -> Result<CommandResponse, CommandDispatchError> {
        Ok(self.service.dispatch_request(request).await)
    }

    fn kind(&self) -> &'static str {
        "local"
    }
}