Skip to content

Commit 6298ff9

Browse files
committed
fixes serialization at couchbase
Signed-off-by: Otavio Santana <[email protected]>
1 parent 0ce971f commit 6298ff9

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

jnosql-couchbase-driver/src/main/java/org/eclipse/jnosql/communication/couchbase/document/DefaultCouchbaseDocumentManager.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -135,9 +135,9 @@ public void delete(DocumentDeleteQuery query) {
135135
Collection collection = bucket.collection(query.getDocumentCollection());
136136
DocumentQuery delete = DeleteQueryWrapper.of(query);
137137
Stream<DocumentEntity> entities = select(delete);
138-
entities.map(d -> d.find(ID_FIELD))
138+
entities.flatMap(d -> d.find(ID_FIELD).stream())
139139
.filter(Objects::nonNull)
140-
.map(Objects::toString)
140+
.map(d -> d.get(String.class))
141141
.forEach(collection::remove);
142142

143143
}

0 commit comments

Comments
 (0)