I have a code which calls couchbase for getting some rows as following: val gotValues: Observable[JsonDocument] = Observable.from(rowKeys).flatMap(id => couchbaseBucket.async().get(id)) If I...