async_flow/error/
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
9impl From<crate::io::PortState> for RecvError {
10    fn from(_input: crate::io::PortState) -> Self {
11        Self
12    }
13}
14
15#[cfg(feature = "flume")]
16impl From<flume::RecvError> for RecvError {
17    fn from(_input: flume::RecvError) -> Self {
18        Self // TODO
19    }
20}