rx-java2 - 使用 Vertx JsonArray 和 RxJava Observables

Question

一个 vertxJsonObject包含一个 vertx JsonArray，类似于：

{
 "myArray":[
   {"id":"1", name:"Yael" },
   {"id":"2", name:"Haddasa"}
 ]
}

使用数组创建 RxJava 的正确方法是什么Observable，以便 observable 将分别处理数组中的每个元素。尝试了以下方法：

JsonArray vertxJsonArray = h.getJsonArray("myArray");
Observable<Object> observable = Observable.fromArray(vertxJsonArray);
observable.flatMapSingle(s -> {
   ...

但是使用上述方法，数组不会分成单独的元素。谢谢

Answer 1

由于JsonArrayimplements Iterable，您可以使用Observable.fromIterable()，如下所示：

@Test
public void from_iterable_test() {
    final TestObserver<Object> testObserver = new TestObserver<>();

    final String json = "{\"myArray\": [{\"id\": \"1\", \"name\": \"Yael\"}, {\"id\": \"2\", \"name\": \"Haddasa\"}] }";

    final JsonObject jsonObject = new JsonObject(json);

    final JsonArray jsonArray = jsonObject.getJsonArray("myArray");

    Observable.fromIterable(jsonArray).subscribe(testObserver);

    assertEquals(jsonArray.size(), testObserver.valueCount());
}