ipc-channel 0.21.0

A multiprocess drop-in replacement for Rust channels
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
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44

use std::fmt::Display;
use std::io;

use thiserror::Error;

#[derive(Debug, Error)]
/// An error that occurs for serialization or deserialization
pub struct SerDeError(#[from] pub(crate) postcard::Error);

impl Display for SerDeError {
    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
        write!(f, "Serialization/Deserialization error")
    }
}

#[derive(Debug, Error)]
pub enum IpcError {
    #[error("Error in decoding or encoding: {0}.")]
    SerializationError(#[from] SerDeError),
    #[error("Error in IO: {0}.")]
    Io(#[from] io::Error),
    /// Disconnected is returned when receiving from a channel if
    /// all senders for the channel have been dropped and no messages
    /// remain to be received.
    #[error("Ipc Disconnected.")]
    Disconnected,
}

#[derive(Debug, Error)]
pub enum TryRecvError {
    #[error("IPC error {0}.")]
    IpcError(#[from] IpcError),
    #[error("Channel empty.")]
    Empty,
}

/// TrySelectError is returned by non-blocking variants of IpcReceiverSet::select.
#[derive(Debug, Error)]
pub enum TrySelectError {
    #[error("Error in IO: {0}.")]
    IoError(#[from] io::Error),
    #[error("No messages were received and no disconnections occurred.")]
    Empty,
}