ReactiveMemoryDataAccessTest#patchByQuery

(cherry picked from commit 7e77091)
doytowin · Dec 6, 2023 · 717569c · 717569c
1 parent d8c96fa
commit 717569c
Show file tree

Hide file tree

Showing 2 changed files with 11 additions 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
@@ -88,7 +88,7 @@ public Mono<Integer> patch(E e) {
 
     @Override
     public Mono<Integer> patch(E e, Q q) {
-        return null;
+        return Mono.fromSupplier(() -> delegate.patch(e, q));
     }
 
     @Override

diff --git a/...ve-memory/src/test/java/win/doyto/query/reactive/menory/ReactiveMemoryDataAccessTest.java b/...ve-memory/src/test/java/win/doyto/query/reactive/menory/ReactiveMemoryDataAccessTest.java
@@ -72,4 +72,14 @@ void deleteByQuery() {
                             .verifyComplete();
     }
 
+    @Test
+    void patchByQuery() {
+        TestEntity testEntity = TestEntity.builder().score(60).build();
+        TestQuery testQuery = TestQuery.builder().valid(true).build();
+        testMemoryDataAccess.patch(testEntity, testQuery)
+                            .as(StepVerifier::create)
+                            .expectNextMatches(i -> i == 3)
+                            .verifyComplete();
+    }
+
 }