From 003b4c9f3b8888d4d1550ea15b51b084de3aa9ab Mon Sep 17 00:00:00 2001 From: Byron Ruth Date: Mon, 14 Aug 2023 13:26:24 -0400 Subject: [PATCH] Fix watch to include only recent events on rev<=0 Signed-off-by: Byron Ruth --- pkg/drivers/nats/backend_test.go | 2 +- pkg/drivers/nats/kv.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/pkg/drivers/nats/backend_test.go b/pkg/drivers/nats/backend_test.go index 9ee14906..e102ae3f 100644 --- a/pkg/drivers/nats/backend_test.go +++ b/pkg/drivers/nats/backend_test.go @@ -376,5 +376,5 @@ func TestBackend_Watch(t *testing.T) { events = append(events, es...) } - expEqual(t, 5, len(events)) + expEqual(t, 1, len(events)) } diff --git a/pkg/drivers/nats/kv.go b/pkg/drivers/nats/kv.go index 4d796d95..e6d60cda 100644 --- a/pkg/drivers/nats/kv.go +++ b/pkg/drivers/nats/kv.go @@ -281,7 +281,7 @@ func (e *KeyValue) watchStream(ctx context.Context, filter, keyPrefix string, st } if startRev <= 0 { - cfg.DeliverPolicy = jetstream.DeliverNewPolicy + cfg.DeliverPolicy = jetstream.DeliverLastPerSubjectPolicy } else { cfg.DeliverPolicy = jetstream.DeliverByStartSequencePolicy cfg.OptStartSeq = startRev