Fix invalid lock

Signed-off-by: Piotr Piotrowski <[email protected]>
nats-io · Jul 19, 2023 · 77c4c1c · 77c4c1c
1 parent 852e1a9
commit 77c4c1c
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/js.go b/js.go
@@ -686,11 +686,11 @@ func (js *js) newAsyncReply() string {
 
 func (js *js) resetPendingAcksOnReconnect() {
  for {
- js.mu.Lock()
  newStatus, ok := <-js.connStatusCh
  if !ok || newStatus == CLOSED {
  return
  }
+ js.mu.Lock()
  for _, paf := range js.pafs {
  paf.err = ErrDisconnected
  }

diff --git a/nats.go b/nats.go
@@ -5471,7 +5471,7 @@ func (nc *Conn) StatusChanged(statuses ...Status) chan Status {
  if len(statuses) == 0 {
  statuses = []Status{CONNECTED, RECONNECTING, DISCONNECTED, CLOSED}
  }
- ch := make(chan Status)
+ ch := make(chan Status, 10)
  for _, s := range statuses {
  nc.registerStatusChangeListener(s, ch)
  }