Fix Send bound for streaming transform

Author: root

src/proxy.rs

@@ -436,7 +436,6 @@ async fn build_proxy_response(
     request_expects_stream: bool,
     moderation_debug: &HeaderMap,
 ) -> Result<Response, ApiError> {
-    let status = upstream_response.status();
     let headers = filtered_response_headers(upstream_response.headers());
     let header_says_stream = is_stream_response(upstream_response.headers());
     if header_says_stream || request_expects_stream {

src/streaming.rs

@@ -52,7 +52,7 @@ enum InternalEvent {
     Done,
 }
 
-trait InternalSink {
+trait InternalSink: Send {
     fn on_start(&mut self, meta: &Map<String, Value>) -> Vec<Vec<u8>>;
     fn on_text_delta(&mut self, text: &str) -> Vec<Vec<u8>>;
     fn on_tool_call_start(&mut self, call_id: &str, name: &str) -> Vec<Vec<u8>>;