dispatch is responsible for calling any async callbacks
()
| 499 | |
| 500 | // dispatch is responsible for calling any async callbacks |
| 501 | func (ac *asyncCallbacksHandler) run() { |
| 502 | for { |
| 503 | f, ok := <-ac.cbQueue |
| 504 | if !ok || f == nil { |
| 505 | return |
| 506 | } |
| 507 | f() |
| 508 | } |
| 509 | } |
| 510 | |
| 511 | // dispatch is responsible for calling any async callbacks |
| 512 | func (ac *asyncCallbacksHandler) push(f func()) { |