entity可用性常规则检查

entity可用性常规则检查

    /**
     * entity可用性常规则检查
     */
    @SuppressWarnings("unchecked")
    public static <T> Observable.Transformer<BaseEntity<T>, T> check() {
        return new Observable.Transformer<BaseEntity<T>, T>() {
            @Override
            public Observable<T> call(Observable<BaseEntity<T>> observable) {
                return observable.flatMap(new Func1<BaseEntity<T>, Observable<T>>() {
                    @Override
                    public Observable<T> call(BaseEntity<T> entity) {
                        if (entity == null) {
                            return Observable.error(new Throwable("获取内容失败"));
                        } else {
                            int code = entity.getCode();
                            if (code == 0) {
                                return Observable.just(entity.getData());
                            } else {
                                return Observable.error(new CatException(entity.getMessage(), code));
                            }
                        }
                    }
                });
            }
        };
    }