MCPcopy Index your code
hub / github.com/riverqueue/river / withLock

Method withLock

internal/notifier/notifier.go:602–606  ·  view source on GitHub ↗
(lockedFunc func())

Source from the content-addressed store, hash-verified

600}
601
602func (n *Notifier) withLock(lockedFunc func()) {
603 n.mu.Lock()
604 defer n.mu.Unlock()
605 lockedFunc()
606}

Callers 2

StartMethod · 0.95
waitOnceMethod · 0.95

Calls

no outgoing calls

Tested by

no test coverage detected