diff --git a/doyto-query-reactive-memory/src/main/java/win/doyto/query/reactive/menory/ReactiveMemoryDataAccess.java b/doyto-query-reactive-memory/src/main/java/win/doyto/query/reactive/menory/ReactiveMemoryDataAccess.java
index b513c9a..5a98e3b 100644
--- a/doyto-query-reactive-memory/src/main/java/win/doyto/query/reactive/menory/ReactiveMemoryDataAccess.java
+++ b/doyto-query-reactive-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