asx-rs 0.14.0

AS2 and AS4 B2B messaging library for Rust — signing, encryption, MDN, and ebMS3/AS4 profile support
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

use std::sync::Arc;

use tokio::sync::mpsc;

use super::AsxEvent;

pub trait EventSink {
    fn emit(
        &self,
        event: AsxEvent,
    ) -> std::pin::Pin<Box<dyn std::future::Future<Output = ()> + Send + '_>>;
}

pub async fn forward_to_sink(
    mut receiver: mpsc::Receiver<AsxEvent>,
    sink: Arc<dyn EventSink + Send + Sync>,
) {
    while let Some(event) = receiver.recv().await {
        sink.emit(event).await;
    }
}