MCPcopy Create free account
hub / github.com/livekit/livekit / NewTypedOpsQueue

Function NewTypedOpsQueue

pkg/utils/opsqueue.go:59–61  ·  view source on GitHub ↗
(params OpsQueueParams)

Source from the content-addressed store, hash-verified

57}
58
59func NewTypedOpsQueue[T any](params OpsQueueParams) *TypedOpsQueue[T] {
60 return &TypedOpsQueue[T]{*newOpsQueueBase[typedQueueOp[T]](params)}
61}
62
63func (oq *TypedOpsQueue[T]) Enqueue(fn func(T), arg T) {
64 oq.opsQueueBase.Enqueue(typedQueueOp[T]{fn, arg})

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…