Upd FaktoryCommand impl for ProgressUpdate

jonhoo · Aug 3, 2024 · 6212ccd · 6212ccd
1 parent a1cfc1d
commit 6212ccd
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 6 deletions.
diff --git a/src/proto/client/ent.rs b/src/proto/client/ent.rs
@@ -11,7 +11,7 @@ impl Client {
     where
         P: AsRef<ProgressUpdate> + Sync,
     {
-        self.issue(&upd).await?.read_ok().await
+        self.issue(upd.as_ref()).await?.read_ok().await
     }
 
     /// Fetch information on a job's execution progress from Faktory.

diff --git a/src/proto/single/ent/cmd.rs b/src/proto/single/ent/cmd.rs
@@ -4,13 +4,10 @@ use crate::proto::{single::FaktoryCommand, JobId};
 use tokio::io::{AsyncWrite, AsyncWriteExt};
 
 #[async_trait::async_trait]
-impl<P> FaktoryCommand for P
-where
-    P: AsRef<ProgressUpdate> + Sync,
-{
+impl FaktoryCommand for ProgressUpdate {
     async fn issue<W: AsyncWrite + Unpin + Send>(&self, w: &mut W) -> Result<(), Error> {
         w.write_all(b"TRACK SET ").await?;
-        let r = serde_json::to_vec(self.as_ref()).map_err(Error::Serialization)?;
+        let r = serde_json::to_vec(self).map_err(Error::Serialization)?;
         w.write_all(&r).await?;
         Ok(w.write_all(b"\r\n").await?)
     }