MCPcopy
hub / github.com/grafana/dskit / AwaitTerminated

Method AwaitTerminated

services/basic_service.go:292–294  ·  view source on GitHub ↗

AwaitTerminated is part of Service interface.

(ctx context.Context)

Source from the content-addressed store, hash-verified

290
291// AwaitTerminated is part of Service interface.
292func (b *BasicService) AwaitTerminated(ctx context.Context) error {
293 return b.awaitState(ctx, Terminated, b.terminatedWaitersCh)
294}
295
296func (b *BasicService) awaitState(ctx context.Context, expectedState State, ch chan struct{}) error {
297 select {

Calls 1

awaitStateMethod · 0.95