Fix POST endpoint URL in proxy stream
This commit is contained in:
1 parent
f9dee11f32
commit
a82521b7be
1 file changed
+1
-1
+1
-1
@@ -156,7 +156,7 @@ async fn sse_handler(
|
|||||||
|
|
||||||
state.clients.write().unwrap().insert(session_id.clone(), tx.clone());
|
state.clients.write().unwrap().insert(session_id.clone(), tx.clone());
|
||||||
|
|
||||||
let _ = tx.send(Ok(Event::default().event("endpoint").data(format!("?sessionId={}", session_id)))).await;
|
let _ = tx.send(Ok(Event::default().event("endpoint").data(format!("/messages?sessionId={}", session_id)))).await;
|
||||||
|
|
||||||
let stream = ReceiverStream::new(rx);
|
let stream = ReceiverStream::new(rx);
|
||||||
Sse::new(stream).keep_alive(axum::response::sse::KeepAlive::new())
|
Sse::new(stream).keep_alive(axum::response::sse::KeepAlive::new())
|
||||||
|
|||||||
Reference in new issue
Block a user