如何在client gRPC中使用Wire with Flow？

// 引入所需的依赖和包

// 使用Wire生成的代码
import com.example.grpc.User;
import com.example.grpc.UserServiceClient;

// 使用Flow处理异步流
import com.example.flow.Flow;
import com.example.flow.Subscriber;
import com.example.flow.Subscription;

public class Client {
    public static void main(String[] args) {
        // 创建gRPC客户端
        UserServiceClient client = new UserServiceClient();

        // 调用gRPC服务端的API
        User user = client.getUser("123");

        // 打印返回的用户信息
        System.out.println(user.getName());

        // 订阅流式数据
        client.getUsersFlow()
              .subscribe(new Subscriber<User>() {
                  public void onSubscribe(Subscription subscription) {
                      // 处理订阅逻辑
                  }
                  
                  public void onNext(User user) {
                      // 处理接收到的流数据
                  }
                  
                  public void onError(Throwable throwable) {
                      // 处理异常
                  }
                  
                  public void onComplete() {
                      // 处理流结束的逻辑
                  }
              });
    }
}