Блог

Я использую spring-data-couchbase с реактивным подходом и получаю следующую ошибку:

Содержимое этого наблюдаемого (viewRow) уже выпущено. Подпишитесь раньше или настройте среду CouchbaseEnvironment#autoreleaseAfter()

Определение метода

 default Flux<NonPrimitiveAsset> findAssetByParameters(StringBuilder whereClause) {

  WherePath selectFrom = N1qlUtils
      .createSelectFromForEntity(getCouchbaseOperations().getCouchbaseBucket().name());

  Statement statement = selectFrom.where(whereClause.toString());

  N1qlQuery query = N1qlQuery.simple(statement, N1qlParams.build());
  return ReactiveWrapperConverters
      .toWrapper(getCouchbaseOperations().findByN1QL(query, NonPrimitiveAsset.class), Flux.class);

}
 

Вызывающий метод

 Flux<NonPrimitiveAsset> assetFlux = repository.findAssetByParameters(whereClause);

Mono<List<NonPrimitiveAsset>> assetsMono = assetFlux.collectList()