invokeCloseCallbacks 触发 close callback, 在独立协程完成
()
| 624 | |
| 625 | // invokeCloseCallbacks 触发 close callback, 在独立协程完成 |
| 626 | func (s *KcpConnection) InvokeCloseCallbacks() { |
| 627 | s.closeCallbackMutex.RLock() |
| 628 | defer s.closeCallbackMutex.RUnlock() |
| 629 | s.closeCallback.Invoke() |
| 630 | } |
| 631 | |
| 632 | // Implement other KCP specific methods here... |
| 633 | // ... |