remove the 4 items enqueued hack

pion · Mar 15, 2024 · 08e52fb · 08e52fb
1 parent e33728d
commit 08e52fb
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 3 deletions.
diff --git a/agent.go b/agent.go
@@ -223,8 +223,6 @@ func (a *Agent) taskLoop() {
 		}
 
 		a.closeMulticastConn()
-		a.updateConnectionState(ConnectionStateClosed)
-
 		after()
 
 		close(a.chanState)
@@ -278,7 +276,7 @@ func NewAgent(config *AgentConfig) (*Agent, error) { //nolint:gocognit
 
 	a := &Agent{
 		chanTask:          make(chan task),
-		chanState:         make(chan ConnectionState, 4),
+		chanState:         make(chan ConnectionState),
 		chanCandidate:     make(chan Candidate),
 		chanCandidatePair: make(chan *CandidatePair),
 		tieBreaker:        globalMathRandomGenerator.Uint64(),

diff --git a/agent_handlers.go b/agent_handlers.go
@@ -51,6 +51,7 @@ func (a *Agent) connectionStateRoutine() {
 	for s := range a.chanState {
 		a.onConnectionStateChange(s)
 	}
+	a.onConnectionStateChange(ConnectionStateClosed)
 }
 
 func (a *Agent) candidateRoutine() {