philipp/oe1-player
1
0
Fork 0
Code Issues 1 Pull Requests Actions Packages Projects Releases Wiki Activity

nicer name
All checks were successful
CI/CD Pipeline / test (push) Successful in 6m29s
Details
CI/CD Pipeline / deploy (push) Successful in 7m30s
Details

Browse Source
This commit is contained in:
Philipp Hofer
2025-11-04 15:57:11 +01:00
parent 250feb54cd
commit 83035c5170
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/web.rs
View File

@@ -4,7 +4,7 @@ use reqwest::header;
use std::sync::Arc; use std::sync::Arc;
use tokio::{net::TcpListener, sync::RwLock}; use tokio::{net::TcpListener, sync::RwLock};
async fn stream_handler(State(state): State<Arc<RwLock<Feed>>>) -> impl IntoResponse { async fn index(State(state): State<Arc<RwLock<Feed>>>) -> impl IntoResponse {
state.write().await.fetch().await.unwrap(); state.write().await.fetch().await.unwrap();
let content = state.read().await.to_rss(); let content = state.read().await.to_rss();
@@ -19,7 +19,7 @@ pub(super) async fn serve(
listener: TcpListener, listener: TcpListener,
) -> Result<(), Box<dyn std::error::Error>> { ) -> Result<(), Box<dyn std::error::Error>> {
let app = Router::new() let app = Router::new()
.route("/", get(stream_handler)) .route("/", get(index))
.with_state(state.clone()); .with_state(state.clone());
axum::serve(listener, app).await?; axum::serve(listener, app).await?;