Skip to content

Commit

Permalink
sync: deprecate mpsc::RecvError (#3833)
Browse files Browse the repository at this point in the history
  • Loading branch information
Darksonn committed Jun 11, 2021
1 parent f759240 commit cb147a2
Show file tree
Hide file tree
Showing 2 changed files with 6 additions and 2 deletions.
4 changes: 2 additions & 2 deletions tokio/src/sync/mpsc/bounded.rs
Expand Up @@ -65,7 +65,7 @@ pub struct Receiver<T> {
/// with backpressure.
///
/// The channel will buffer up to the provided number of messages. Once the
/// buffer is full, attempts to `send` new messages will wait until a message is
/// buffer is full, attempts to send new messages will wait until a message is
/// received from the channel. The provided buffer capacity must be at least 1.
///
/// All data sent on `Sender` will become available on `Receiver` in the same
Expand All @@ -76,7 +76,7 @@ pub struct Receiver<T> {
///
/// If the `Receiver` is disconnected while trying to `send`, the `send` method
/// will return a `SendError`. Similarly, if `Sender` is disconnected while
/// trying to `recv`, the `recv` method will return a `RecvError`.
/// trying to `recv`, the `recv` method will return `None`.
///
/// # Panics
///
Expand Down
4 changes: 4 additions & 0 deletions tokio/src/sync/mpsc/error.rs
Expand Up @@ -55,14 +55,18 @@ impl<T> From<SendError<T>> for TrySendError<T> {

/// Error returned by `Receiver`.
#[derive(Debug)]
#[doc(hidden)]
#[deprecated(note = "This type is unused because recv returns an Option.")]
pub struct RecvError(());

#[allow(deprecated)]
impl fmt::Display for RecvError {
fn fmt(&self, fmt: &mut fmt::Formatter<'_>) -> fmt::Result {
write!(fmt, "channel closed")
}
}

#[allow(deprecated)]
impl Error for RecvError {}

cfg_time! {
Expand Down

0 comments on commit cb147a2

Please sign in to comment.