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

Function WaitAllStarted

rivershared/startstop/start_stop.go:317–319  ·  view source on GitHub ↗

WaitAllStarted waits until all the given services are started (or stopped in a degenerate start scenario, like if context is cancelled while starting up). Unlike StopAllParallel, WaitAllStarted doesn't bother with parallelism because the services themselves have already backgrounded themselves, and

(services ...Service)

Source from the content-addressed store, hash-verified

315// because the services themselves have already backgrounded themselves, and we
316// have to wait until the slowest service has started anyway.
317func WaitAllStarted(services ...Service) {
318 <-WaitAllStartedC(services...)
319}
320
321// WaitAllStartedC waits until all the given services are started (or stopped in
322// a degenerate start scenario, like if context is cancelled while starting up).

Callers 3

StartMethod · 0.92
StartMethod · 0.92
TestWaitAllStartedFunction · 0.85

Calls 1

WaitAllStartedCFunction · 0.85

Tested by 1

TestWaitAllStartedFunction · 0.68

Used in the wild real call sites across dependent graphs

searching dependent graphs…