MCPcopy
hub / github.com/livekit/livekit / Done

Method Done

pkg/utils/incrementaldispatcher.go:50–55  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

48}
49
50func (d *IncrementalDispatcher[T]) Done() {
51 d.lock.Lock()
52 d.done.Break()
53 d.cond.Broadcast()
54 d.lock.Unlock()
55}
56
57func (d *IncrementalDispatcher[T]) ForEach(fn func(T)) {
58 idx := 0

Callers 15

TestForEachFunction · 0.80
TestConcurrentConsumptionFunction · 0.80
WithTimeoutFunction · 0.80
deleteRoomMethod · 0.80
TestRoomLockFunction · 0.80
notifySessionMethod · 0.80
untilTransportsConnectedFunction · 0.80
TestParticipantDataBlob_ConcurrentAccessFunction · 0.80
benchmarkPoolFunction · 0.80
benchmarkGoroutineFunction · 0.80
benchmarkLoadBalancedFunction · 0.80
benchmarkLoadBalancedPoolFunction · 0.80

Calls 1

BroadcastMethod · 0.80

Tested by 15

TestForEachFunction · 0.64
TestConcurrentConsumptionFunction · 0.64
TestRoomLockFunction · 0.64
untilTransportsConnectedFunction · 0.64
TestParticipantDataBlob_ConcurrentAccessFunction · 0.64
benchmarkPoolFunction · 0.64
benchmarkGoroutineFunction · 0.64
benchmarkLoadBalancedFunction · 0.64
benchmarkLoadBalancedPoolFunction · 0.64
WriteMethod · 0.64
TestNackFunction · 0.64
TestFractionLostReportFunction · 0.64