tdd is fun sometimes

replicator/replicator_test.go

@@ -29,6 +29,17 @@ func TestReplicatorStream(t *testing.T) {
 				}
 			},
 		},
+		"one during op moves": {
+			during: func(t *testing.T, r Replicator) {
+				r.Src.Set(nil, key, value, version)
+				time.Sleep(time.Millisecond * 200)
+			},
+			after: func(t *testing.T, r Replicator) {
+				if got, _ := r.Dest.Get(nil, key); !got.Version.Equal(version) || !got.Value.Equal(value) {
+					t.Error(got)
+				}
+			},
+		},
 	}
 
 	for name, d := range cases {