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