MCPcopy Create free account
hub / github.com/LagrangeDev/LagrangeGo / dispatch

Method dispatch

client/event.go:29–40  ·  view source on GitHub ↗
(client *QQClient, event T)

Source from the content-addressed store, hash-verified

27}
28
29func (handle *EventHandle[T]) dispatch(client *QQClient, event T) {
30 eventMu.RLock()
31 defer func() {
32 eventMu.RUnlock()
33 if pan := recover(); pan != nil {
34 client.error("event error: %v\n%s", pan, debug.Stack())
35 }
36 }()
37 for _, handler := range handle.handlers {
38 handler(client, event)
39 }
40}
41
42type eventHandlers struct {
43 subscribedEventHandlers []any

Callers 5

decodeKickNTPacketFunction · 0.80
quickReconnectMethod · 0.80
unexpectedDisconnectMethod · 0.80
netLoopMethod · 0.80

Calls 1

errorMethod · 0.80

Tested by

no test coverage detected