support for GET call to return a stream; use it in Responses GET with stream

Author: 64bit

async-openai/src/client.rs

@@ -544,23 +544,18 @@ impl<C: Config> Client<C> {
     }
 
     /// Make HTTP GET request to receive SSE
-    pub(crate) async fn _get_stream<Q, O>(
+    pub(crate) async fn get_stream<O>(
         &self,
         path: &str,
-        query: &Q,
+        request_options: &RequestOptions,
     ) -> Pin<Box<dyn Stream<Item = Result<O, OpenAIError>> + Send>>
     where
-        Q: Serialize + ?Sized,
         O: DeserializeOwned + std::marker::Send + 'static,
     {
-        let event_source = self
-            .http_client
-            .get(self.config.url(path))
-            .query(query)
-            .query(&self.config.query())
-            .headers(self.config.headers())
-            .eventsource()
-            .unwrap();
+        let request_builder =
+            self.build_request_builder(reqwest::Method::GET, path, request_options);
+
+        let event_source = request_builder.eventsource().unwrap();
 
         stream(event_source).await
     }

async-openai/src/responses.rs

@@ -81,6 +81,25 @@ impl<'c, C: Config> Responses<'c, C> {
             .await
     }
 
+    /// Retrieves a model response with the given ID with streaming.
+    ///
+    /// Response events will be sent as server-sent events as they become available.
+    #[crate::byot(
+        T0 = std::fmt::Display,
+        R = serde::de::DeserializeOwned,
+        stream = "true",
+        where_clause = "R: std::marker::Send + 'static"
+    )]
+    pub async fn retrieve_stream(&self, response_id: &str) -> Result<ResponseStream, OpenAIError> {
+        let mut request_options = self.request_options.clone();
+        request_options.with_query(&[("stream", "true")])?;
+
+        Ok(self
+            .client
+            .get_stream(&format!("/responses/{}", response_id), &request_options)
+            .await)
+    }
+
     /// Deletes a model response with the given ID.
     #[crate::byot(T0 = std::fmt::Display, R = serde::de::DeserializeOwned)]
     pub async fn delete(&self, response_id: &str) -> Result<DeleteResponse, OpenAIError> {