arbiter 0.5.0

A framework for building distributed systems with actors.
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 thiserror::Error;
#[cfg(not(target_arch = "wasm32"))]
use tokio::task::JoinError as TaskJoinError;
#[cfg(target_arch = "wasm32")]
use tokio_with_wasm::task::JoinError as TaskJoinError;

/// The primary error type used throughout `arbiter-core`.
#[derive(Debug, Error)]
pub enum ArbiterError {
  /// The underlying communication channel was closed unexpectedly.
  #[error("channel closed unexpectedly")]
  ChannelClosed,

  /// A spawned actor task panicked during execution.
  #[error("spawned task panicked")]
  TaskPanicked(#[from] TaskJoinError),

  /// The snapshot stream for the actor was already taken and cannot be taken again.
  #[error("snapshot stream already taken")]
  StreamAlreadyTaken,
}

/// A specialized [`Result`] type for Arbiter operations.
pub type Result<T> = std::result::Result<T, ArbiterError>;