chore(rs-transport): improve error messages

Signed-off-by: Roman Volosatovs <[email protected]>

Author: rvolosatovs

Cargo.lock

@@ -1,6 +1,6 @@
 [package]
 name = "wrpc-transport"
-version = "0.26.0"
+version = "0.26.1"
 description = "wRPC core transport functionality"
 
 authors.workspace = true

crates/transport/Cargo.toml

@@ -1564,7 +1564,7 @@ where
                 try_join!(
                     async {
                         tx.send(item).map_err(|_| {
-                            std::io::Error::new(std::io::ErrorKind::BrokenPipe, "receiver closed")
+                            std::io::Error::new(std::io::ErrorKind::BrokenPipe, "future receiver closed")
                         })
                     },
                     async {
@@ -1955,7 +1955,7 @@ where
                 })?;
                 trace!(i, end, "received stream chunk");
                 tx.send(chunk).await.map_err(|_| {
-                    std::io::Error::new(std::io::ErrorKind::BrokenPipe, "receiver closed")
+                    std::io::Error::new(std::io::ErrorKind::BrokenPipe, "stream receiver closed")
                 })?;
                 for (i, deferred) in zip(i.., mem::take(&mut framed.decoder_mut().deferred)) {
                     if let Some(deferred) = deferred {
@@ -2075,7 +2075,7 @@ where
                     }
                     trace!(?chunk, "received byte stream chunk");
                     tx.send(chunk).await.map_err(|_| {
-                        std::io::Error::new(std::io::ErrorKind::BrokenPipe, "receiver closed")
+                        std::io::Error::new(std::io::ErrorKind::BrokenPipe, "stream receiver closed")
                     })?;
                 }
                 Ok(())
@@ -2145,7 +2145,7 @@ where
                     }
                     trace!(?chunk, "received byte stream chunk");
                     tx.send(std::io::Result::Ok(chunk)).await.map_err(|_| {
-                        std::io::Error::new(std::io::ErrorKind::BrokenPipe, "receiver closed")
+                        std::io::Error::new(std::io::ErrorKind::BrokenPipe, "stream receiver closed")
                     })?;
                 }
                 Ok(())