RX Java Наблюдаемый оператор из списка в список HashMap - PullRequest
Новая
       19

RX Java Наблюдаемый оператор из списка в список HashMap

0 голосов
/ 28 мая 2020

У меня есть массив Observable. Мне нужно вывести список HashMap. Но я получаю только один элемент массива на выходе.

Если вход [1,2,3,4]

Выход должен быть {"results":[1,2,3,4]}

У меня есть следующее: 

result.flatMap(asyncN1qlQueryResult ->
  asyncN1qlQueryResult.errors().flatMap(error -> {
    return Observable
      .error(new Exception("unable to execute n1ql query " + error.toString()));
  })
  .switchIfEmpty(asyncN1qlQueryResult.rows())
).map(row -> {
    JsonObject json = ((AsyncN1qlQueryRow) row).value();
    return json;
  }).map(json -> {
    sbResults.append(json.toString());
    sbResults.append(",");log.info(" sbresults : " + sbResults.toString());
    return sbResults;
  })
  .map(results -> {
    resultMap.put("results", results.toString());
    return resultMap;
  });

Похоже, это не работает, потому что я получаю только один элемент на выходе.

...