object_transfer 0.0.3

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

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

use crate::error::AckError;
use crate::traits::AckTrait;

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