async_flow/error/
try_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("TryRecvError")]
7pub struct TryRecvError;
8
9#[cfg(feature = "flume")]
10impl From<flume::TryRecvError> for TryRecvError {
11    fn from(_input: flume::TryRecvError) -> Self {
12        Self // TODO
13    }
14}
15
16#[cfg(feature = "tokio")]
17impl From<tokio::sync::mpsc::error::TryRecvError> for TryRecvError {
18    fn from(_input: tokio::sync::mpsc::error::TryRecvError) -> Self {
19        Self // TODO
20    }
21}