Closed
Description
AbstractCouchbaseQuery needs to implement Stream queries :
} else if (getQueryMethod().isStreamQuery()) {
return (q, t, c) -> operation.matching(q.with(accessor.getPageable())).stream();
ReactiveAbstractCouchbaseQuery needs to implement Stream queries. It cannot do exactly as AbstractCouchbaseQuery, though, because all reactive queries have isStreamQuery() == true;