rsiot/components/cmp_websocket_server/
errors.rs

1use crate::{components::shared_tasks, serde_utils};
2
3#[allow(missing_docs)]
4#[derive(Debug, thiserror::Error)]
5pub enum Error {
6    #[error("{0}")]
7    Tungstenite(#[from] tokio_tungstenite::tungstenite::Error),
8
9    #[error("Error bind to port: {0}")]
10    BindToPort(std::io::Error),
11
12    #[error("{0}")]
13    TokioTaskJoin(#[from] tokio::task::JoinError),
14
15    #[error("TokioSyncMpsc")]
16    TokioSyncMpsc,
17
18    #[error("{0}")]
19    FnInput(anyhow::Error),
20
21    #[error("Error: {err}, text from client: {data}")]
22    FnOutput { err: anyhow::Error, data: String },
23
24    #[error("Client disconnected")]
25    ClientDisconnected,
26
27    #[error(transparent)]
28    CmpOutput(crate::executor::ComponentError),
29
30    #[error("TaskEndInput")]
31    TaskEndInput,
32
33    #[error("TaskEndOutput")]
34    TaskEndOutput,
35
36    #[error(transparent)]
37    SharedTaskMsgBusToMpsc(shared_tasks::msgbus_to_mpsc::Error),
38
39    #[error(transparent)]
40    SharedTaskMpscToMsgBus(shared_tasks::mpsc_to_msgbus::Error),
41
42    #[error(transparent)]
43    Serde(#[from] serde_utils::Error),
44}