使用Observables RxJava进行文件验证

Question

我正在尝试使用Rxjava解决一个经典的文件验证过程。我有一个带有正常标头的CSV文件和另一个标头列表，我需要验证它们是否属于所选数据类型或值是否为空。

我已经用普通java实现了这一点，但我想让我的验证代码更具反应性。这就是我到目前为止所取得的成就。

String filePath = "/home/user/Documents/test.csv";
Path path = Paths.get(filePath);
Map<String,String> headerMap = new HashMap<>();
headerMap.put("feild11","String");
headerMap.put("feild10","String");
headerMap.put("feild9","Date");
headerMap.put("feild8","NOT-NULL");

// An map observalble which defines my valdiation rules
Observable<Map<String,String>> fieldsToValidae = Observable.just(headerMap);

Observable<String> fileObservalbe = RxFileReader.from(path);
// An observalbe which gives a list of headers
Observable<String> headers = fileObservalbe.first();

// An observalbe which gives me list of feild values
Observable<String> feildValues = fileObservalbe.skip(1);

在这里，我有3个可观察对象要组合和验证，在验证失败的第一个实例（行）中。

以下是我想使用的示例数据：

标题：

名字|姓|性别|出生|出生|出生|出生|出生|出生|出生|出生|出生|出生|出生|出生|出生|出生|出生|出生|出生|出生|出生|出生|出生|出生

价值观：

Prakash | joshi | M | 2015年11月25日| a fdf f | adf | saf | asf | dfadf | sadf | ASDFDFDF | asdf | DFSFDED Prakash | joshi | M | 2015年10月25日| a fdf f | adf | saf | asf | dfadf | dfadf |124; sadf | asdf | ASDFDF | asdf | DFSFDED Prakash | joshi | M | 2015年10月25日| a fdf f | adf | saf | asf | dfadf | sadf | asdf | asdf | DFSFDED

我几乎被困在这一点上，谁能帮我或给我指出正确的方向？

Answer 1

使用组合最新运算符，在标头和字段中传递（据我所知，您将发出一个标头和许多字段），并在函数传递逻辑中进行数据验证

Observable<Result> validationResultObservable = Observable.combineLatest(headers, feildValues, new Func2<String, String, Result>() {
            @Override
            public Result call(String header, String field) {
                // header always same
                // field always new
                // validate, create same kind of Result object or just a boolean
                Log.i("TEST_IT", "validationResultObservable emitted: " + header + " - " + field);
                return new Result(header, field);
            }
        });