feat!: improve error handling

examples/auth.rs

@@ -136,10 +136,10 @@ mod storage {
                     StorageMessage::Auth(msg) => {
                         let WithChannels { inner, tx, .. } = msg;
                         if authed {
-                            conn.close(1u32.into(), b"invalid message");
+                            conn.close(400u32.into(), b"invalid message");
                             break;
                         } else if inner.token != self.auth_token {
-                            conn.close(1u32.into(), b"permission denied");
+                            conn.close(401u32.into(), b"permission denied");
                             break;
                         } else {
                             authed = true;
@@ -148,7 +148,7 @@ mod storage {
                     }
                     msg => {
                         if !authed {
-                            conn.close(1u32.into(), b"permission denied");
+                            conn.close(401u32.into(), b"permission denied");
                             break;
                         } else {
                             self.handle_authenticated(msg).await;

src/channel.rs

@@ -14,9 +14,13 @@ pub mod oneshot;
 /// For rpc communication, there can be any number of errors, so this is a
 /// generic io error.
 #[stack_error(derive, add_meta, from_sources)]
+#[non_exhaustive]
 pub enum SendError {
-    /// The receiver has been closed. This is the only error that can occur
-    /// for local communication.
+    /// The receiver has been closed.
+    ///
+    /// This is the only error that can occur for local communication. For
+    /// remote communication, this means that the receiver stopped the stream
+    /// with code 0, for example because it was dropped.
     #[error("Receiver closed")]
     ReceiverClosed,
     /// The message exceeded the maximum allowed message size (see [`MAX_MESSAGE_SIZE`]).

src/channel/mpsc.rs

@@ -14,6 +14,7 @@ use super::SendError;
 /// For rpc communication, there can be any number of errors, so this is a
 /// generic io error.
 #[stack_error(derive, add_meta, from_sources)]
+#[non_exhaustive]
 pub enum RecvError {
     /// The message exceeded the maximum allowed message size (see [`MAX_MESSAGE_SIZE`]).
     ///

src/channel/oneshot.rs

@@ -14,9 +14,13 @@ use crate::util::FusedOneshotReceiver;
 /// For rpc communication, there can be any number of errors, so this is a
 /// generic io error.
 #[stack_error(derive, add_meta, from_sources)]
+#[non_exhaustive]
 pub enum RecvError {
-    /// The sender has been closed. This is the only error that can occur
-    /// for local communication.
+    /// The sender has been closed.
+    ///
+    /// This is the only error that can occur for local communication. For
+    /// remote communication, this means that the sender finished the stream
+    /// without sending, for example because it was dropped.
     #[error("Sender closed")]
     SenderClosed,
     /// The message exceeded the maximum allowed message size (see [`MAX_MESSAGE_SIZE`]).

src/lib.rs

@@ -949,6 +949,7 @@ impl<M> ClientInner<M> {
 /// Error when opening a request. When cross-process rpc is disabled, this is
 /// an empty enum since local requests can not fail.
 #[stack_error(derive, add_meta, from_sources)]
+#[non_exhaustive]
 pub enum RequestError {
     /// Error in noq during connect
     #[cfg(feature = "rpc")]
@@ -976,6 +977,7 @@ pub enum RequestError {
 
 /// Error type that subsumes all possible errors in this crate, for convenience.
 #[stack_error(derive, add_meta, from_sources)]
+#[non_exhaustive]
 pub enum Error {
     #[error("Request error")]
     Request { source: RequestError },