Roguelite-Game-Developing-Team/Gen_Hack-and-Slash-Roguelite
2
0
Fork 2
Code Issues Pull Requests Actions Packages Projects Releases 1 Activity

(server) fix:The main thread will no longer be blocked

Browse Source
This commit is contained in:
TheRedApricot
2025-08-28 16:47:35 +08:00
parent c3bff1cf88
commit b03fbbacae
2 changed files with 11 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
Server/src/command_helper.rs
View File

@ -4,7 +4,6 @@ pub(crate) fn run() {
let stdin = std::io::stdin(); let stdin = std::io::stdin();
loop { loop {
print!("> ");
std::io::stdout() std::io::stdout()
.flush() .flush()
.expect("Failed to flush standard output!"); .expect("Failed to flush standard output!");

19
Server/src/grpc_server.rs
View File

@ -1,5 +1,6 @@
use std::net::SocketAddr; use std::net::SocketAddr;
use tokio::task;
use tonic::transport::Server; use tonic::transport::Server;
use tonic_web::GrpcWebLayer; use tonic_web::GrpcWebLayer;
@ -17,13 +18,15 @@ impl GrpcServer {
let general_service = GeneralServiceServer::new(GeneralServiceImpl); let general_service = GeneralServiceServer::new(GeneralServiceImpl);
let game_service = GameServiceServer::new(GameServiceImpl); let game_service = GameServiceServer::new(GameServiceImpl);
Server::builder() task::spawn(async move {
.accept_http1(true) Server::builder()
.layer(GrpcWebLayer::new()) .accept_http1(true)
.add_service(general_service) .layer(GrpcWebLayer::new())
.add_service(game_service) .add_service(general_service)
.serve(addr) .add_service(game_service)
.await .serve(addr)
.unwrap_or_else(|e| log::error!("Failed to build server: {e}")); .await
.unwrap_or_else(|e| log::error!("Failed to build server: {e}"));
});
} }
} }