style: simplification of async closure

Author: georgeh0

src/llm/anthropic.rs

@@ -90,14 +90,13 @@ impl LlmGenerationClient for Client {
         let encoded_api_key = encode(&self.api_key);
 
         let resp = retryable::run(
-            || async {
+            || {
                 self.client
                     .post(url)
                     .header("x-api-key", encoded_api_key.as_ref())
                     .header("anthropic-version", "2023-06-01")
                     .json(&payload)
                     .send()
-                    .await
             },
             &retryable::HEAVY_LOADED_OPTIONS,
         )

src/llm/gemini.rs

@@ -114,7 +114,7 @@ impl LlmGenerationClient for Client {
 
         let url = self.get_api_url(request.model, "generateContent");
         let resp = retryable::run(
-            || async { self.client.post(&url).json(&payload).send().await },
+            || self.client.post(&url).json(&payload).send(),
             &retryable::HEAVY_LOADED_OPTIONS,
         )
         .await?;
@@ -173,7 +173,7 @@ impl LlmEmbeddingClient for Client {
             payload["taskType"] = serde_json::Value::String(task_type.into());
         }
         let resp = retryable::run(
-            || async { self.client.post(&url).json(&payload).send().await },
+            || self.client.post(&url).json(&payload).send(),
             &retryable::HEAVY_LOADED_OPTIONS,
         )
         .await?;

src/llm/ollama.rs

@@ -66,12 +66,11 @@ impl LlmGenerationClient for Client {
             stream: Some(false),
         };
         let res = retryable::run(
-            || async {
+            || {
                 self.reqwest_client
                     .post(self.generate_url.as_str())
                     .json(&req)
                     .send()
-                    .await
             },
             &retryable::HEAVY_LOADED_OPTIONS,
         )

src/llm/voyage.rs

@@ -76,13 +76,12 @@ impl LlmEmbeddingClient for Client {
         }
 
         let resp = retryable::run(
-            || async {
+            || {
                 self.client
                     .post(url)
                     .header("Authorization", format!("Bearer {}", self.api_key))
                     .json(&payload)
                     .send()
-                    .await
             },
             &retryable::HEAVY_LOADED_OPTIONS,
         )