refactor ReactiveMemoryDataAccess#query

doytowin · Dec 6, 2023 · 6b3914c · 6b3914c
1 parent 7e77091
commit 6b3914c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...active-memory/src/main/java/win/doyto/query/reactive/menory/ReactiveMemoryDataAccess.java b/...active-memory/src/main/java/win/doyto/query/reactive/menory/ReactiveMemoryDataAccess.java
@@ -48,7 +48,7 @@ public Mono<E> create(E e) {
 
     @Override
     public Flux<E> query(Q q) {
-        return Flux.fromStream(() -> delegate.query(q).stream());
+        return Flux.fromIterable(delegate.query(q));
     }
 
     @Override