如何使用akka客户端websocket向websocket服务器发出多个请求

<dependency>
    <groupId>com.typesafe.akka</groupId>
    <artifactId>akka-actor_2.12</artifactId>
    <version>2.6.16</version>
</dependency>
<dependency>
    <groupId>com.typesafe.akka</groupId>
    <artifactId>akka-stream_2.12</artifactId>
    <version>2.6.16</version>
</dependency>
<dependency>
    <groupId>com.typesafe.akka</groupId>
    <artifactId>akka-http_2.12</artifactId>
    <version>10.2.6</version>
</dependency>

import akka.actor.ActorSystem;
import akka.http.javadsl.ConnectHttp;
import akka.http.javadsl.Http;
import akka.http.javadsl.model.*;
import akka.http.javadsl.model.ws.*;
import akka.stream.ActorMaterializer;
import akka.stream.Materializer;
import akka.stream.javadsl.*;

public class WebSocketClientExample {
    public static void main(String[] args) {
        // 创建Actor系统和材料化器
        ActorSystem system = ActorSystem.create();
        Materializer materializer = ActorMaterializer.create(system);

        // 创建WebSocket客户端
        WebSocketRequest request = WebSocketRequest.create("ws://example.com/websocket");
        Flow<Message, Message, CompletionStage<WebSocketUpgradeResponse>> webSocketFlow =
                Http.get(system).webSocketClientFlow(request, materializer);

        // 发送多个请求
        Source<Message, Sink<Message, CompletionStage<Done>>> source =
                Source.from(List.of("Request 1", "Request 2", "Request 3"))
                        .map(TextMessage::create);
        Sink<Message, CompletionStage<Done>> sink =
                Sink.foreach(message -> System.out.println("Received response: " + message.asTextMessage().getStrictText()));
        RunnableGraph<CompletionStage<Done>> graph =
                source.viaMat(webSocketFlow, Keep.right()).to(sink);

        // 运行图形
        CompletionStage<Done> completion = graph.run(materializer);
        completion.thenRun(system::terminate);
    }
}