mirror of
https://github.com/gogrlx/nats-server.git
synced 2026-04-02 03:38:42 -07:00
PR feedback: nit
This commit is contained in:
@@ -4670,11 +4670,11 @@ func TestMQTTLockedSession(t *testing.T) {
|
||||
// It is possible, however unlikely, to have received CONNACK while
|
||||
// mqttProcessConnect is still running, and the session remains locked. Wait
|
||||
// for it to finish.
|
||||
stillLocked := true
|
||||
for stillLocked {
|
||||
for stillLocked := true; stillLocked; {
|
||||
asm.mu.RLock()
|
||||
_, stillLocked = asm.sessLocked["sub"]
|
||||
asm.mu.RUnlock()
|
||||
|
||||
if stillLocked {
|
||||
time.Sleep(1 * time.Millisecond)
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user