We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent fbf22c3 commit b335b31Copy full SHA for b335b31
proxy-http-server/src/routes/subscribe.rs
@@ -14,9 +14,8 @@ use std::sync::Arc;
14
use crate::webapp_state::WebApplicationState;
15
use intersect_ingress_proxy_common::signals::wait_for_os_signal;
16
17
-#[allow(clippy::needless_pass_by_value)]
18
fn sse_response(
19
- app_state: Arc<impl WebApplicationState>,
+ app_state: &Arc<impl WebApplicationState>,
20
) -> Sse<impl Stream<Item = Result<Event, Infallible>>> {
21
let mut rx = app_state.get_broadcaster().add_client();
22
@@ -65,5 +64,5 @@ pub async fn sse_handler(
65
64
{
66
return (StatusCode::UNAUTHORIZED, "unauthorized").into_response();
67
}
68
- sse_response(app_state).into_response()
+ sse_response(&app_state).into_response()
69
0 commit comments