diff options
author | Alex Auvolat <alex@adnab.me> | 2022-07-22 13:01:52 +0200 |
---|---|---|
committer | Alex Auvolat <alex@adnab.me> | 2022-07-22 13:01:52 +0200 |
commit | 9cb28c21b4a80aa9f29097f6bb1b8b6c23446ddc (patch) | |
tree | 855113a2db9414eabf0f1c2402942ad9bd09fea8 /src/error.rs | |
parent | 0b71ca12f910c17eaf2291076438dff3b70dc9cd (diff) | |
download | netapp-9cb28c21b4a80aa9f29097f6bb1b8b6c23446ddc.tar.gz netapp-9cb28c21b4a80aa9f29097f6bb1b8b6c23446ddc.zip |
Use bounded channels on receive side for backpressure
Diffstat (limited to 'src/error.rs')
-rw-r--r-- | src/error.rs | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/src/error.rs b/src/error.rs index 665647c..f374341 100644 --- a/src/error.rs +++ b/src/error.rs @@ -28,6 +28,9 @@ pub enum Error { #[error(display = "Framing protocol error")] Framing, + #[error(display = "Request ID collision")] + IdCollision, + #[error(display = "{}", _0)] Message(String), @@ -56,6 +59,7 @@ impl Error { Self::Framing => 13, Self::NoHandler => 20, Self::ConnectionClosed => 21, + Self::IdCollision => 22, Self::Handshake(_) => 30, Self::VersionMismatch(_) => 31, Self::Remote(c, _) => *c, |