actually apply all messages.
This commit is contained in:
parent
6d1e711b2a
commit
dabe14889d
@ -169,7 +169,7 @@ func executeMessageVector(t *testing.T, vector *schema.TestVector) {
|
||||
driver := NewDriver(ctx, vector)
|
||||
|
||||
// Apply every message.
|
||||
for i, m := range vector.ApplyMessages[:len(vector.ApplyMessages)-1] {
|
||||
for i, m := range vector.ApplyMessages {
|
||||
msg, err := types.DecodeMessage(m.Bytes)
|
||||
if err != nil {
|
||||
t.Fatalf("failed to deserialize message: %s", err)
|
||||
|
Loading…
Reference in New Issue
Block a user