pub async fn stream_handler( __arg0: Path<String>, __arg1: Query<StreamQuery>, __arg2: State<AppState>, ) -> Sse<impl Stream<Item = Result<Event, Infallible>>>