有没有办法从Grpc-request获取进度消息？

// 定义进度消息
message Progress {
  int32 percentage = 1;
}

// 定义服务方法
service MyService {
  rpc LongRunningTask (google.protobuf.Empty) returns (stream Progress);
}

// 服务器端实现
service MyService {
  rpc LongRunningTask (google.protobuf.Empty) returns (stream Progress) {
    // 模拟长时间运行的任务
    for (int i = 0; i <= 100; i++) {
      // 发送进度消息给客户端
      Progress progress = Progress.newBuilder().setPercentage(i).build();
      responseObserver.onNext(progress);
      Thread.sleep(1000); // 模拟任务执行时间
    }
    responseObserver.onCompleted();
  }
}

// 客户端调用
ManagedChannel channel = ManagedChannelBuilder.forAddress("localhost", 50051).usePlaintext().build();
MyServiceGrpc.MyServiceStub stub = MyServiceGrpc.newStub(channel);

stub.longRunningTask(Empty.getDefaultInstance(), new StreamObserver<Progress>() {
  @Override
  public void onNext(Progress progress) {
    // 处理进度消息
    System.out.println("Progress: " + progress.getPercentage() + "%");
  }

  @Override
  public void onError(Throwable t) {
    // 处理错误
  }

  @Override
  public void onCompleted() {
    // 处理完成
  }
});