refactor: factor out serdes of T in send/recv

channels/src/receiver.rs

@@ -270,6 +270,21 @@ where
 	}
 }
 
+impl<T, R, D> Receiver<T, R, D>
+where
+	D: Deserializer<T>,
+{
+	#[inline]
+	fn deserialize_t<Io>(
+		&mut self,
+		data: &mut [u8],
+	) -> Result<T, RecvError<D::Error, Io>> {
+		self.deserializer
+			.deserialize(data)
+			.map_err(RecvError::Serde)
+	}
+}
+
 impl<T, R, D> Receiver<T, R, D>
 where
 	R: AsyncRead,
@@ -301,9 +316,7 @@ where
 		)
 		.await?;
 
-		self.deserializer
-			.deserialize(&mut payload)
-			.map_err(RecvError::Serde)
+		self.deserialize_t(&mut payload)
 	}
 }
 
@@ -341,9 +354,7 @@ where
 			&mut self.reader,
 		)?;
 
-		self.deserializer
-			.deserialize(&mut payload)
-			.map_err(RecvError::Serde)
+		self.deserialize_t(&mut payload)
 	}
 }
 

channels/src/sender.rs

@@ -231,6 +231,19 @@ where
 	}
 }
 
+impl<T, W, S> Sender<T, W, S>
+where
+	S: Serializer<T>,
+{
+	#[inline]
+	fn serialize_t<Io>(
+		&mut self,
+		t: &T,
+	) -> Result<Vec<u8>, SendError<S::Error, Io>> {
+		self.serializer.serialize(t).map_err(SendError::Serde)
+	}
+}
+
 impl<T, W, S> Sender<T, W, S>
 where
 	W: AsyncWrite,
@@ -262,10 +275,7 @@ where
 	where
 		D: Borrow<T>,
 	{
-		let payload = self
-			.serializer
-			.serialize(data.borrow())
-			.map_err(SendError::Serde)?;
+		let payload = self.serialize_t(data.borrow())?;
 
 		crate::protocol::send_async(
 			&self.config,
@@ -314,10 +324,7 @@ where
 	where
 		D: Borrow<T>,
 	{
-		let payload = self
-			.serializer
-			.serialize(data.borrow())
-			.map_err(SendError::Serde)?;
+		let payload = self.serialize_t(data.borrow())?;
 
 		crate::protocol::send_sync(
 			&self.config,