Couchbase Java / Scala получить список неудачных идентификаторов

Question

Я заблудился в rx.Observable API и мне нужна помощь.

Я бы хотел удалить большую часть документа в сегменте CB. Мне нужно получить список идентификаторов ошибочных документов. Предполагалось, что-то вроде этого:

val ids = Seq[String]("1","5","3","4","2")

rx.lang.scala.Observable.from(ids).flatMap(id=> akkaBucket.async().remove(id).onErrorResumeNext(e => Observable.just(JsonDocument.create(id)))).toSeq.subscribe(
    x => println(x),
    e => e.printStackTrace(),
    () => ()
  )

Хотя это Scala Code и я использую RX Scala Observable, но я буду рад любой помощи в Java.