style(mcp): rustfmt
This commit is contained in:
1 parent
36a28dc096
commit
386be75658
1 file changed
+11
-7
@@ -54,7 +54,11 @@ impl HttpServerHandle {
|
||||
/// routing) on an already-bound loopback listener. Every request must present
|
||||
/// `Authorization: Bearer <token>` matching the stored token (constant-time
|
||||
/// compare, `mcp::token::verify`) or it never reaches `rmcp`.
|
||||
pub(crate) fn serve(listener: TcpListener, expected_token: String, handler: WaMcpHandler) -> HttpServerHandle {
|
||||
pub(crate) fn serve(
|
||||
listener: TcpListener,
|
||||
expected_token: String,
|
||||
handler: WaMcpHandler,
|
||||
) -> HttpServerHandle {
|
||||
let local_addr = listener
|
||||
.local_addr()
|
||||
.expect("a just-bound TcpListener has a local addr");
|
||||
@@ -65,11 +69,7 @@ pub(crate) fn serve(listener: TcpListener, expected_token: String, handler: WaMc
|
||||
..Default::default()
|
||||
};
|
||||
let session_manager = Arc::new(LocalSessionManager::default());
|
||||
let service = StreamableHttpService::new(
|
||||
move || Ok(handler.clone()),
|
||||
session_manager,
|
||||
config,
|
||||
);
|
||||
let service = StreamableHttpService::new(move || Ok(handler.clone()), session_manager, config);
|
||||
|
||||
let accept_ct = shutdown.clone();
|
||||
let join = tokio::spawn(async move {
|
||||
@@ -99,7 +99,11 @@ pub(crate) fn serve(listener: TcpListener, expected_token: String, handler: WaMc
|
||||
}
|
||||
});
|
||||
|
||||
HttpServerHandle { local_addr, shutdown, join }
|
||||
HttpServerHandle {
|
||||
local_addr,
|
||||
shutdown,
|
||||
join,
|
||||
}
|
||||
}
|
||||
|
||||
async fn handle_request(
|
||||
|
||||
Reference in new issue
Block a user