summaryrefslogtreecommitdiffstats
path: root/tokio/src/sync/mpsc/unbounded.rs
diff options
context:
space:
mode:
authorVojtech Kral <vojtech@kral.hk>2020-04-04 19:36:12 +0200
committerGitHub <noreply@github.com>2020-04-04 19:36:12 +0200
commitd65bf3805be376505f5c2fb0724cec8917dfb813 (patch)
treef4ac1d82cdf8332b49cb7f5cbcf18d80e2229974 /tokio/src/sync/mpsc/unbounded.rs
parent7c1bc460f7eccbeef62504d4799b6bccc909e46c (diff)
doc: add error explanation for UnboundedSender::send() (#2372)
Diffstat (limited to 'tokio/src/sync/mpsc/unbounded.rs')
-rw-r--r--tokio/src/sync/mpsc/unbounded.rs7
1 files changed, 7 insertions, 0 deletions
diff --git a/tokio/src/sync/mpsc/unbounded.rs b/tokio/src/sync/mpsc/unbounded.rs
index b6b621d2..ba543fe4 100644
--- a/tokio/src/sync/mpsc/unbounded.rs
+++ b/tokio/src/sync/mpsc/unbounded.rs
@@ -162,6 +162,13 @@ impl<T> UnboundedSender<T> {
}
/// Attempts to send a message on this `UnboundedSender` without blocking.
+ ///
+ /// If the receive half of the channel is closed, either due to [`close`]
+ /// being called or the [`UnboundedReceiver`] having been dropped,
+ /// the function returns an error. The error includes the value passed to `send`.
+ ///
+ /// [`close`]: UnboundedReceiver::close
+ /// [`UnboundedReceiver`]: UnboundedReceiver
pub fn send(&self, message: T) -> Result<(), SendError<T>> {
self.chan.send_unbounded(message)?;
Ok(())