如何在Actix-web中正确调用WebSocket处理程序中的异步函数

use actix_web::{web, App, HttpRequest, HttpResponse, HttpServer, Responder};
use actix_web_actors::ws;
use futures::stream::StreamExt;

async fn websocket_handler(
    req: HttpRequest,
    stream: web::Payload,
) -> Result<HttpResponse, actix_web::Error> {
    let res = ws::start_with_protocols(MyWebSocket::new(), &req, stream, None);
    res
}

struct MyWebSocket;

impl MyWebSocket {
    fn new() -> Self {
        MyWebSocket
    }
}

impl Actor for MyWebSocket {
    type Context = ws::WebsocketContext<Self>;
}

impl StreamHandler<Result<ws::Message, ws::ProtocolError>> for MyWebSocket {
    fn handle(&mut self, msg: Result<ws::Message, ws::ProtocolError>, ctx: &mut Self::Context) {
        match msg {
            Ok(ws::Message::Ping(msg)) => ctx.pong(&msg),
            Ok(ws::Message::Text(text)) => {
                // 在这里调用异步函数处理文本消息
                ctx.spawn(async move {
                    // 调用异步函数
                    let result = async_function(text).await;
                    // 处理异步函数的结果
                    match result {
                        Ok(response) => {
                            // 发送响应消息给客户端
                            ctx.text(response).await.unwrap();
                        }
                        Err(err) => {
                            // 发送错误消息给客户端
                            ctx.text(format!("Error: {}", err)).await.unwrap();
                        }
                    }
                });
            }
            _ => (),
        }
    }
}

#[actix_rt::main]
async fn main() -> std::io::Result<()> {
    HttpServer::new(|| {
        App::new()
            .route("/ws/", web::get().to(websocket_handler))
    })
    .bind("127.0.0.1:8080")?
    .run()
    .await
}