shared stream optimizations

This commit is contained in:
euzu
2025-07-28 15:50:05 +02:00
parent b3c88ef6db
commit ec848ca050
2 changed files with 1 additions and 4 deletions
+1 -3
View File
@@ -954,9 +954,7 @@ async fn shared_stream_response(
if let Some(stream) =
SharedStreamManager::subscribe_shared_stream(app_state, stream_url, Some(addr)).await
{
debug_if_enabled!(
"Using shared stream {}",
sanitize_sensitive_info(stream_url)
debug_if_enabled!("Using shared stream {}", sanitize_sensitive_info(stream_url)
);
if let Some(headers) = app_state
.shared_stream_manager
@@ -263,7 +263,6 @@ impl SharedStreamManager {
self.unregister(stream_url.as_ref().unwrap(), true).await;
}
}
async fn subscribe_stream(&self, stream_url: &str, addr: Option<&str>, manager: Arc<SharedStreamManager>) -> Option<BoxedProviderStream> {