Method AddSubscriber

pkg/rtc/datatrack.go:116–151

(sub types.LocalParticipant)

}

func (d *DataTrack) AddSubscriber(sub types.LocalParticipant) (types.DataDownTrack, error) {
	d.lock.Lock()
	defer d.lock.Unlock()

	if _, ok := d.subscribedTracks[sub.ID()]; ok {
		return nil, errAlreadySubscribed
	}

	bytesStats := NewBytesTrackStats(
		sub.GetCountry(),
		d.ID(),
		sub.ID(),
		sub.Kind(),
		sub.KindDetails(),
		sub.GetTelemetryListener(),
		sub.GetReporter(),
	)
	dataDownTrack, err := NewDataDownTrack(DataDownTrackParams{
		Logger:           sub.GetLogger().WithValues("trackID", d.ID()),
		SubscriberID:     sub.ID(),
		PublishDataTrack: d,
		Handle:           sub.GetNextSubscribedDataTrackHandle(),
		Transport:        sub.GetDataTrackTransport(),
		BytesTrackStats:  bytesStats,
	})
	if err != nil {
		bytesStats.Stop()
		return nil, err
	}

	d.subscribedTracks[sub.ID()] = subscribedDataTrack{
		subscriber:    sub,
		dataDownTrack: dataDownTrack,
	}
	return dataDownTrack, nil
}

func (d *DataTrack) RemoveSubscriber(subID livekit.ParticipantID) {
	d.lock.Lock()