从过滤序列中获得最后一个未过滤结果的惯用方法是什么？

Question

        class SimpleWrapper<T> {
        private T data;

        public T getData() {
            return data;
        }

        public void setData(T data) {
            this.data = data;
        }
    }

    SimpleWrapper<String> state = new SimpleWrapper<>();

    Observable<Response> getLogObservable = Observable.interval(checkInterval, TimeUnit.SECONDS)
            .take(checkCount)
            .flatMap(ignored -> api.check())
            .doOnNext(response -> {
                logger.info("Check response: {}", response.getMessage());
                state.setData(response.getMessage());
            })
            .firstOrDefault(null, HubLogsApiResponse::isSuccess)
            .flatMap(response -> {
                if (response == null) {
                    return Observable.error(new RuntimeException(String.format("Last call to check was unsuccessful: %s", state.getData())));
                } else {
                    return Observable.just(response);
                }
            })

这是丑陋的，需要我使用副作用，但我不知道如何才能实现这一点。

有什么建议吗？

Answer 1

问题：发出一系列请求，或者返回成功的第一个请求，或者返回错误的最后一个请求。

如果我们引入一个对，就可以将interval产生的计数与API请求结合起来。然后，不需要设置全局变量就可以检查终止条件。

Observable<Response> getLogObservable = 
  Observable.interval(checkInterval, TimeUnit.SECONDS)
        .flatMap(requestNumber -> api.check()
                                    .map(response -> 
                                         new Pair(requestNumber+1, response))
        .flatMap(pair -> mapResponse( pair ) )
        .take( 1 );

Observable<Response> mapResponse( Pair<Long, Response> response ) {
  if ( response.getSecond().isSuccess() ) {
    return Observable.just( response.getSecond() );
  }
  if ( response.getFirst() >= checkCount ) {
    Observable.error(
      new RuntimeException(String.format("Last call to check was unsuccessful: %s", 
            pair.getSecond().getData())));
  }
  return Observable.empty();
}

mapresponse仅在计数器运行其过程时才生成包含最新响应的错误。否则，它返回一个成功的响应或一个空的Observable。