From 3f1f6e4893315a84a5312b3e9eeb5d3cf95ab242 Mon Sep 17 00:00:00 2001 From: Brad Stein Date: Mon, 16 Jun 2025 22:14:52 -0500 Subject: [PATCH] server updates --- server/src/main.rs | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/server/src/main.rs b/server/src/main.rs index e5bafda..be352b4 100644 --- a/server/src/main.rs +++ b/server/src/main.rs @@ -22,8 +22,8 @@ struct Handler { } #[tonic::async_trait] -impl Relay for Handler { - }type StreamStream = +impl Relay for Handler { + type StreamStream = Pin> + Send + 'static>>; async fn stream( @@ -34,7 +34,7 @@ impl Relay for Handler { let mut in_stream = request.into_inner(); let kb = self.kb.clone(); let ms = self.ms.clone(); - let (tx, rx) = tokio::sync::mpsc::channel::>(32); + let (tx, rx) = tokio::sync::mpsc::channel::>(32); tokio::spawn(async move { // catch panics so that they are logged instead of killing the task silently