object_transfer 2.0.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
17
18
19
20
21
22
23
24

use ::serde::de::Error as DeErr;
use ::thiserror::Error;

use super::BrokerError;
use super::ack::AckError;
use super::decode::DecodeError;

/// Error type for subscription operations in the messaging system.
#[derive(Error, Debug)]
pub enum SubError<DecodeErrorType: DeErr + Send + Sync> {
  /// Broker error.
  #[error("Broker error: {0}")]
  BrokerError(#[from] BrokerError),
  /// Acknowledgment error.
  #[error("Acknowledgment error: {0}")]
  AckError(#[from] AckError),
  /// Decoding error for deserialization failures.
  #[error("Decoding error: {0}")]
  DecodeError(#[from] DecodeError<DecodeErrorType>),
  /// Generic error variant for miscellaneous errors (Test use only).
  #[cfg(test)]
  #[error("Error Test")]
  ErrorTest,
}