(
State(state): State<Arc<ServerState>>,
)
| 4296 | } |
| 4297 | |
| 4298 | async fn event_stream( |
| 4299 | State(state): State<Arc<ServerState>>, |
| 4300 | ) -> Sse<impl Stream<Item = std::result::Result<Event, Infallible>>> { |
| 4301 | let rx = state.event_bus.subscribe(); |
| 4302 | Sse::new(BroadcastStream::new(rx).filter_map(|result| match result { |
| 4303 | Ok(event) => Some(Ok(Event::default().data(event))), |
| 4304 | Err(_) => None, |
| 4305 | })) |
| 4306 | } |
| 4307 | |
| 4308 | #[derive(Debug, Serialize)] |
| 4309 | struct PathsResponse { |