object_transfer 1.2.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
14
15
16
17
18
19
20
21
22
23
24
25
26

use ::std::fmt::{Debug, Display};

use ::async_nats::error::Error as NatsKindError;
use ::thiserror::Error;

use crate::errors::BrokerError;

/// Error type for NATS SubFetcher operations.
#[derive(Error, Debug)]
pub enum NatsSubFetcherError {
  /// Error during the creation of a JetStream stream.
  #[error("NATS JetStream Stream Creation Error: {0}")]
  JetStreamStreamCreation(
    #[from] async_nats::jetstream::context::CreateStreamError,
  ),
}

impl<T> From<NatsKindError<T>> for BrokerError
where
  T: Debug + Display + Clone + PartialEq + Send + Sync + 'static,
{
  /// Converts the error from brokers into a BrokerError.
  fn from(e: NatsKindError<T>) -> Self {
    BrokerError::new(e)
  }
}