object_transfer 1.1.0

An object transfer library for various message broker and/or protocols
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16

use async_nats::jetstream::message::Acker;
use async_trait::async_trait;
use futures::TryFutureExt;

use crate::errors::AckError;
use crate::traits::AckTrait;

#[async_trait]
impl AckTrait for Acker {
  async fn ack(&self) -> Result<(), AckError> {
    self
      .ack()
      .map_err(|e| AckError::BrokerError(e.into()))
      .await
  }
}