fix: clear sync.Map properly (#630)

Author: anunaym14

localparticipant.go

@@ -545,8 +545,10 @@ func (p *LocalParticipant) handleParticipantDisconnected(identity string) {
 
 	p.rpcPendingResponses.Range(func(key, value interface{}) bool {
 		if value.(rpcPendingResponseHandler).participantIdentity == identity {
-			value.(rpcPendingResponseHandler).resolve(nil, rpcErrorFromBuiltInCodes(RpcRecipientDisconnected, nil))
-			p.rpcPendingResponses.Delete(key)
+			value, ok := p.rpcPendingResponses.LoadAndDelete(key)
+			if ok {
+				value.(rpcPendingResponseHandler).resolve(nil, rpcErrorFromBuiltInCodes(RpcRecipientDisconnected, nil))
+			}
 		}
 		return true
 	})
@@ -660,8 +662,8 @@ func (p *LocalParticipant) PerformRpc(params PerformRpcParams) (*string, error)
 }
 
 func (p *LocalParticipant) cleanup() {
-	p.rpcPendingAcks = &sync.Map{}
-	p.rpcPendingResponses = &sync.Map{}
+	p.rpcPendingAcks.Clear()
+	p.rpcPendingResponses.Clear()
 }
 
 // StreamText creates a new text stream writer with the provided options.

remoteparticipant.go

@@ -15,7 +15,6 @@
 package lksdk
 
 import (
-	"sync"
 	"time"
 
 	"github.com/pion/webrtc/v4"
@@ -171,14 +170,7 @@ func (p *RemoteParticipant) unpublishAllTracks() {
 		}
 		return true
 	})
-	eraseSyncMap(p.tracks)
-	eraseSyncMap(p.audioTracks)
-	eraseSyncMap(p.videoTracks)
-}
-
-func eraseSyncMap(m *sync.Map) {
-	m.Range(func(key interface{}, value interface{}) bool {
-		m.Delete(key)
-		return true
-	})
+	p.tracks.Clear()
+	p.audioTracks.Clear()
+	p.videoTracks.Clear()
 }

room.go

@@ -860,11 +860,11 @@ func (r *Room) cleanup() {
 	r.engine.Close()
 	r.LocalParticipant.closeTracks()
 	r.setSid("", true)
-	r.byteStreamHandlers = &sync.Map{}
-	r.byteStreamReaders = &sync.Map{}
-	r.textStreamHandlers = &sync.Map{}
-	r.textStreamReaders = &sync.Map{}
-	r.rpcHandlers = &sync.Map{}
+	r.byteStreamHandlers.Clear()
+	r.byteStreamReaders.Clear()
+	r.textStreamHandlers.Clear()
+	r.textStreamReaders.Clear()
+	r.rpcHandlers.Clear()
 	r.LocalParticipant.cleanup()
 }