如何正确使用 Java 中 Apollo Client 的 RxJava2 库进行同步调用？

Posted 2023-03-08

【中文标题】如何正确使用 Java 中 Apollo Client 的 RxJava2 库进行同步调用？

【英文标题】：How can I use the RxJava2 library for the Apollo Client in Java properly for synchronous calls?

【发布时间】：2020-09-05 05:10:25

【问题描述】：

RxJava2 可用于Apollo GraphQL JVM。但我可以弄清楚如何正确使用它。我尝试同步使用它：

/**
 * This method is supposed to send an Apollo Call, map the data of the Responses into Optionals and 
 * give back the Optional<Data> object.
 * @param <T>: the build query
 * @param <V>: the expected data structure
 *
*/
    public static <T extends com.apollographql.apollo.api.Query> Optional<Data> execute(
            T operation) 
        ApolloClient client = new CommonClient().getClient();
        ApolloCall<Data> apolloCall = client.query(operation);
        return Rx2Apollo.from(apolloCall)
                .map(value -> Optional.of(value.data()))
                .onErrorReturn(o ->  
                  logger.error(o.getMessage());
                  return Optional.empty();
                )
                .blockingFirst();
    

但问题是我在 .map(value -> Optional.of(value.data())) 行上遇到错误。错误是：

java.util.Optional 不能转换为 com.example.graphql.client.KundeQuery$Data

那么，我做错了什么？或者至少有一种更简单的方法来同步处理 Apollo GraphQL JVM Client 中的数据？

【参考方案1】：

我已经知道了。传入的数据结构是 Response> 而不是 >。所以它无法读取它。解决方案可能是这样的：

public static <T extends com.apollographql.apollo.api.Query> Optional<Data> execute(T operation) 

    ApolloClient client = new CommonClient().getClient();
    ApolloCall<Optional<Data>> apolloCall = client.query(operation);

    return Rx2Apollo.from(apolloCall)
            .map(IncomingResponse::extracted)
            .onErrorReturn(o -> 
                logger.error(o.getMessage());
                return Optional.empty();
                )
            .blockingFirst();


private static Optional<Data> extracted(Response<Optional<Data>> value) 
    Optional<Data> result = value.data();
    return result; //Optional.of(localData);