Code
Hub
Workspaces
Connect
Indexed graphs
Engine
MCP
copy
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
602
func
(n *Notifier) withLock(lockedFunc
func
()) {
603
n.mu.Lock()
604
defer
n.mu.Unlock()
605
lockedFunc()
606
}
Callers
2
Start
Method · 0.95
waitOnce
Method · 0.95
Calls
no outgoing calls
Tested by
no test coverage detected