StopAsync is part of Service interface.
()
| 226 | |
| 227 | // StopAsync is part of Service interface. |
| 228 | func (b *BasicService) StopAsync() { |
| 229 | if s := b.State(); s == Stopping || s == Terminated || s == Failed { |
| 230 | // no need to do anything |
| 231 | return |
| 232 | } |
| 233 | |
| 234 | terminated, _ := b.switchState(New, Terminated, func() { |
| 235 | // Service wasn't started yet, and it won't be now. |
| 236 | // Notify waiters and listeners. |
| 237 | close(b.runningWaitersCh) |
| 238 | close(b.terminatedWaitersCh) |
| 239 | b.notifyListeners(func(l Listener) { l.Terminated(New) }, true) |
| 240 | }) |
| 241 | |
| 242 | if !terminated { |
| 243 | // Service is Starting or Running. Just cancel the context (it must exist, |
| 244 | // as it is created when switching from New to Starting state) |
| 245 | b.serviceCancel() |
| 246 | } |
| 247 | } |
| 248 | |
| 249 | // ServiceContext returns context that this service uses internally for controlling its lifecycle. It is the same context that |
| 250 | // is passed to Starting and Running functions, and is based on context passed to the service via StartAsync. |
nothing calls this directly
no test coverage detected