-
Notifications
You must be signed in to change notification settings - Fork 192
Closed
Labels
type: bugA general bugA general bug
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;
Metadata
Metadata
Assignees
Labels
type: bugA general bugA general bug