pub async fn exec_stream(
__arg0: Query<StreamQuery>,
) -> Result<Sse<impl Stream<Item = Result<Event, Infallible>>>, (StatusCode, String)>Expand description
SSE handler:从 EXEC_STREAMS 取出 receiver(取出即移除,防重复连接), 包成 ReceiverStream,映射成 SSE Event 流。