Add OrderTag to Req and Resp, refactor errors

1 files changed, 6 insertions, 2 deletions

diff --git a/src/recv.rs b/src/recv.rs
index f8606f3..b5289fb 100644
--- a/src/recv.rs
+++ b/src/recv.rs
@@ -35,7 +35,10 @@ impl Sender {
 impl Drop for Sender {
 	fn drop(&mut self) {
 		if let Some(inner) = self.inner.take() {
-			let _ = inner.send(Err(std::io::Error::new(std::io::ErrorKind::BrokenPipe, "Netapp connection dropped before end of stream")));
+			let _ = inner.send(Err(std::io::Error::new(
+				std::io::ErrorKind::BrokenPipe,
+				"Netapp connection dropped before end of stream",
+			)));
 		}
 	}
 }
@@ -82,7 +85,8 @@ pub(crate) trait RecvLoop: Sync + 'static {
 
 			let packet = if is_error {
 				let kind = u8_to_io_errorkind(next_slice[0]);
-				let msg = std::str::from_utf8(&next_slice[1..]).unwrap_or("<invalid utf8 error message>");
+				let msg =
+					std::str::from_utf8(&next_slice[1..]).unwrap_or("<invalid utf8 error message>");
 				debug!("recv_loop: got id {}, error {:?}: {}", id, kind, msg);
 				Some(Err(std::io::Error::new(kind, msg.to_string())))
 			} else {