Merge pull request #1688 from nats-io/fix2

Flush after purge too
2026-04-15 10:40:41 -07:00 · 2020-11-01 13:37:15 -08:00
parent e0c79edec4 d729beb24c
commit debf474a3a
1 changed files with 2 additions and 0 deletions
--- a/test/jetstream_test.go
+++ b/test/jetstream_test.go
@@ -2459,6 +2459,8 @@ func TestJetStreamAckReplyStreamPending(t *testing.T) {
 			expectPending(toSend*2 - 2)
 			// Purge and send a new one.
 			mset.Purge()
+			nc.Flush()
+
 			sendStreamMsg(t, nc, "foo.1", "Hello World!")
 			expectPending(0)
 			for i := 0; i < toSend; i++ {