refactor: make body_to_output associated method to share between threads

src/chat.rs

@@ -155,7 +155,7 @@ impl<'a> Task for TaskChat<'a> {
         client.post(format!("{base}/chat/completions")).json(&body)
     }
 
-    fn body_to_output(&self, mut response: Self::ResponseBody) -> Self::Output {
+    fn body_to_output(mut response: Self::ResponseBody) -> Self::Output {
         response.choices.pop().unwrap()
     }
 }

src/completion.rs

@@ -212,7 +212,7 @@ impl Task for TaskCompletion<'_> {
         client.post(format!("{base}/complete")).json(&body)
     }
 
-    fn body_to_output(&self, mut response: Self::ResponseBody) -> Self::Output {
+    fn body_to_output(mut response: Self::ResponseBody) -> Self::Output {
         response.completions.pop().unwrap()
     }
 }

src/detokenization.rs

@@ -51,7 +51,7 @@ impl<'a> Task for TaskDetokenization<'a> {
         client.post(format!("{base}/detokenize")).json(&body)
     }
 
-    fn body_to_output(&self, response: Self::ResponseBody) -> Self::Output {
+    fn body_to_output(response: Self::ResponseBody) -> Self::Output {
         DetokenizationOutput::from(response)
     }
 }

src/explanation.rs

@@ -174,7 +174,7 @@ impl Task for TaskExplanation<'_> {
         client.post(format!("{base}/explain")).json(&body)
     }
 
-    fn body_to_output(&self, response: Self::ResponseBody) -> Self::Output {
+    fn body_to_output(response: Self::ResponseBody) -> Self::Output {
         ExplanationOutput::from(response)
     }
 }

src/http.rs

@@ -28,7 +28,7 @@ pub trait Job {
     fn build_request(&self, client: &reqwest::Client, base: &str) -> RequestBuilder;
 
     /// Parses the response of the server into higher level structs for the user.
-    fn body_to_output(&self, response: Self::ResponseBody) -> Self::Output;
+    fn body_to_output(response: Self::ResponseBody) -> Self::Output;
 }
 
 /// A task send to the Aleph Alpha Api using the http client. Requires to specify a model before it
@@ -45,7 +45,7 @@ pub trait Task {
     fn build_request(&self, client: &reqwest::Client, base: &str, model: &str) -> RequestBuilder;
 
     /// Parses the response of the server into higher level structs for the user.
-    fn body_to_output(&self, response: Self::ResponseBody) -> Self::Output;
+    fn body_to_output(response: Self::ResponseBody) -> Self::Output;
 
     /// Turn your task into [`Job`] by annotating it with a model name.
     fn with_model<'a>(&'a self, model: &'a str) -> MethodJob<'a, Self>
@@ -77,8 +77,8 @@ where
         self.task.build_request(client, base, self.model)
     }
 
-    fn body_to_output(&self, response: T::ResponseBody) -> T::Output {
-        self.task.body_to_output(response)
+    fn body_to_output(response: Self::ResponseBody) -> Self::Output {
+        T::body_to_output(response)
     }
 }
 
@@ -161,7 +161,7 @@ impl HttpClient {
     pub async fn output_of<T: Job>(&self, task: &T, how: &How) -> Result<T::Output, Error> {
         let response = self.request(task, how).await?;
         let response_body: T::ResponseBody = response.json().await?;
-        let answer = task.body_to_output(response_body);
+        let answer = T::body_to_output(response_body);
         Ok(answer)
     }
 

src/semantic_embedding.rs

@@ -76,7 +76,7 @@ impl Task for TaskSemanticEmbedding<'_> {
         client.post(format!("{base}/semantic_embed")).json(&body)
     }
 
-    fn body_to_output(&self, response: Self::ResponseBody) -> Self::Output {
+    fn body_to_output(response: Self::ResponseBody) -> Self::Output {
         response
     }
 }
@@ -94,7 +94,7 @@ impl Job for TaskSemanticEmbedding<'_> {
         client.post(format!("{base}/semantic_embed")).json(&body)
     }
 
-    fn body_to_output(&self, response: Self::ResponseBody) -> Self::Output {
+    fn body_to_output(response: Self::ResponseBody) -> Self::Output {
         response
     }
 }
@@ -141,7 +141,7 @@ impl Job for TaskBatchSemanticEmbedding<'_> {
             .json(&body)
     }
 
-    fn body_to_output(&self, response: Self::ResponseBody) -> Self::Output {
+    fn body_to_output(response: Self::ResponseBody) -> Self::Output {
         response
     }
 }

src/stream.rs

@@ -65,7 +65,7 @@ impl Task for TaskStreamCompletion<'_> {
         client.post(format!("{base}/complete")).json(&body)
     }
 
-    fn body_to_output(&self, response: Self::ResponseBody) -> Self::Output {
+    fn body_to_output(response: Self::ResponseBody) -> Self::Output {
         response
     }
 }

src/tokenization.rs

@@ -85,7 +85,7 @@ impl Task for TaskTokenization<'_> {
         client.post(format!("{base}/tokenize")).json(&body)
     }
 
-    fn body_to_output(&self, response: Self::ResponseBody) -> Self::Output {
+    fn body_to_output(response: Self::ResponseBody) -> Self::Output {
         TokenizationOutput::from(response)
     }
 }