async_flow/io/
recv_error.rs

1// This is free and unencumbered software released into the public domain.
2
3use thiserror::Error;
4
5#[derive(Clone, Copy, Debug, Eq, Error, PartialEq)]
6#[error("RecvError")]
7pub struct RecvError;
8
9#[cfg(feature = "flume")]
10impl From<flume::RecvError> for RecvError {
11    fn from(_input: flume::RecvError) -> Self {
12        Self // TODO
13    }
14}
15
16#[derive(Clone, Copy, Debug, Eq, Error, PartialEq)]
17#[error("TryRecvError")]
18pub struct TryRecvError;
19
20#[cfg(feature = "flume")]
21impl From<flume::TryRecvError> for TryRecvError {
22    fn from(_input: flume::TryRecvError) -> Self {
23        Self // TODO
24    }
25}
26
27#[cfg(feature = "tokio")]
28impl From<tokio::sync::mpsc::error::TryRecvError> for TryRecvError {
29    fn from(_input: tokio::sync::mpsc::error::TryRecvError) -> Self {
30        Self // TODO
31    }
32}