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

我必须在一行中多次调用外部API方法,直到尝试不足或收到肯定的响应为止。如果尝试次数不足,我仍然希望使用(出于日志记录/诊断目的)最新的未成功响应。目前我是这样做的:

        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);
                }
            })

这很难看,需要我使用副作用,但我不知道如何才能做到这一点。

有什么建议吗?