dandri/livekit
1
0
Fork 0
mirror of https://github.com/livekit/livekit.git synced 2026-08-28 20:38:20 +00:00
Code Issues Packages Projects Releases Wiki Activity

support immediate disconnect via Leave

Browse Source
This commit is contained in:
David Zhao
2021-04-08 22:06:43 -07:00
parent b0b28e4499
commit 9aa6fc29f5
9 changed files with 254 additions and 160 deletions
Download Patch File Download Diff File Expand all files Collapse all files
cmd/cli/client/client.go
+12 -2
View File
@@ -251,11 +251,16 @@ func (c *RTCClient) Run() error {
return err
}
case *livekit.SignalResponse_Update:
c.lock.Lock()
participants := make(map[string]*livekit.ParticipantInfo)
for _, p := range msg.Update.Participants {
c.remoteParticipants[p.Sid] = p
if p.State != livekit.ParticipantInfo_DISCONNECTED {
participants[p.Sid] = p
}
}
c.lock.Lock()
c.remoteParticipants = participants
c.lock.Unlock()
case *livekit.SignalResponse_TrackPublished:
logger.Debugw("track published", "track", msg.TrackPublished.Track.Name, "participant", c.localParticipant.Sid,
"cid", msg.TrackPublished.Cid, "trackSid", msg.TrackPublished.Track.Sid)
@@ -337,6 +342,11 @@ func (c *RTCClient) RemoteParticipants() []*livekit.ParticipantInfo {
}
func (c *RTCClient) Stop() {
_ = c.SendRequest(&livekit.SignalRequest{
Message: &livekit.SignalRequest_Leave{
Leave: &livekit.LeaveRequest{},
},
})
c.connected.TrySet(false)
c.iceConnected.TrySet(false)
c.conn.Close()