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 {