fix: Receiver pool can sometimes crash when a disconnect occurs unexp…

…ectedly
driskell · Jul 19, 2024 · 3553db5 · 3553db5
1 parent e246e01
commit 3553db5
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/lc-lib/receiver/pool.go b/lc-lib/receiver/pool.go
@@ -223,6 +223,7 @@ ReceiverLoop:
  connection := eventImpl.Context().Value(transports.ContextConnection)
  r.apiConnections.RemoveEntry(r.connectionStatus[connection].remote)
  delete(r.connectionStatus, connection)
+ r.scheduler.Remove(connection)
  r.connectionLock.Unlock()
  case *transports.StatusEvent:
  if eventImpl.StatusChange() == transports.Finished {