@@ -25,10 +25,10 @@ async fn main() -> anyhow::Result<()> {
25
25
async fn http_server ( req : Request < Incoming > ) -> Result < hyper:: Response < String > , hyper:: Error > {
26
26
tokio:: spawn ( async move {
27
27
if let Err ( e) = async {
28
- let upgraded = hyper:: upgrade:: on ( req) . await ?;
29
- let service = Calculator . serve ( TokioIo :: new ( upgraded) ) . await ?;
30
- service. waiting ( ) . await ?;
31
- Ok :: < ( ) , anyhow:: Error > ( ( ) )
28
+ let upgraded = hyper:: upgrade:: on ( req) . await ?;
29
+ let service = Calculator . serve ( TokioIo :: new ( upgraded) ) . await ?;
30
+ service. waiting ( ) . await ?;
31
+ Ok :: < ( ) , anyhow:: Error > ( ( ) )
32
32
} . await {
33
33
tracing:: error!( "Service error: {:?}" , e) ;
34
34
}
@@ -41,6 +41,7 @@ async fn http_server(req: Request<Incoming>) -> Result<hyper::Response<String>,
41
41
Ok ( response)
42
42
}
43
43
44
+
44
45
async fn http_client ( uri : & str ) -> anyhow:: Result < RunningService < RoleClient , ( ) > > {
45
46
let tcp_stream = tokio:: net:: TcpStream :: connect ( uri) . await ?;
46
47
let ( mut s, c) =
@@ -51,7 +52,7 @@ async fn http_client(uri: &str) -> anyhow::Result<RunningService<RoleClient, ()>
51
52
. insert ( UPGRADE , HeaderValue :: from_static ( "mcp" ) ) ;
52
53
let response = s. send_request ( req) . await ?;
53
54
let upgraded = hyper:: upgrade:: on ( response) . await ?;
54
- let client = RoleClient . serve ( TokioIo :: new ( upgraded) ) . await ?;
55
+ let client = ( ) . serve ( TokioIo :: new ( upgraded) ) . await ?;
55
56
Ok ( client)
56
57
}
57
58
0 commit comments