mirror of
https://github.com/gogrlx/nats-server.git
synced 2026-04-17 11:24:44 -07:00
flush immediately on creation
This commit is contained in:
@@ -357,9 +357,11 @@ func TestConnzLastActivity(t *testing.T) {
|
||||
|
||||
nc := createClientConnSubscribeAndPublish(t)
|
||||
defer nc.Close()
|
||||
nc.Flush()
|
||||
|
||||
nc2 := createClientConnSubscribeAndPublish(t)
|
||||
defer nc2.Close()
|
||||
nc2.Flush()
|
||||
|
||||
pollConz := func() *Connz {
|
||||
url := fmt.Sprintf("http://localhost:%d/", MONITOR_PORT)
|
||||
|
||||
Reference in New Issue
Block a user