Function stop

flow-plugins/src/video_server.rs:66–73

(#[data] state: State, id: u64)

#[post("/stop/{id}")]
#[openapi(summary = "stop a video stream by id")]
async fn stop(#[data] state: State, id: u64) -> RwebResult {
    if let Some((_, sender)) = state.mapping.lock().await.remove(&id) {
        sender.close();
        Ok(format!("stop stream {} success", id))
    } else {
        Err(reject::not_found())
    }
}

#[get("/list")]
#[openapi(summary = "list all video streams")]