(#[data] state: State, url: String)
| 55 | #[post("/start/{url}")] |
| 56 | #[openapi(summary = "start a video stream")] |
| 57 | async fn start(#[data] state: State, url: String) -> RwebResult { |
| 58 | let id = state.id(); |
| 59 | let (s, r) = oneshot::channel(); |
| 60 | state.sender.send((id, url, s)).await.ok(); |
| 61 | r.await.unwrap() |
| 62 | } |
| 63 | |
| 64 | #[post("/stop/{id}")] |
| 65 | #[openapi(summary = "stop a video stream by id")] |