update tests

8xFF · Dec 13, 2024 · 5d5f61c · 5d5f61c
1 parent a1170b6
commit 5d5f61c
Showing 1 changed file with 11 additions and 0 deletions.
diff --git a/src/service/replicate_kv_service/remote_storage.rs b/src/service/replicate_kv_service/remote_storage.rs
@@ -422,6 +422,17 @@ mod tests {
         assert_eq!(ctx.outs.pop_front(), Some(Event::KvEvent(KvEvent::Set(Some(1), 1, 2))));
         assert_eq!(ctx.outs.pop_front(), Some(Event::KvEvent(KvEvent::Set(Some(1), 1, 1))));
         assert_eq!(ctx.outs.pop_front(), None);
+
+        // after received FetchChanged, it should be rejected
+        state.on_rpc_res(
+            &mut ctx,
+            RpcRes::FetchChanged(Ok(vec![Changed {
+                key: 1,
+                version: Version(1),
+                action: Action::Set(2),
+            }])),
+        );
+        assert_eq!(ctx.outs.pop_front(), None);
     }
 
     /// After missing changed we got FetchChanged response