We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent b83dc67 commit 5b4c05cCopy full SHA for 5b4c05c
socket.go
@@ -83,6 +83,7 @@ type BaseSocket struct {
83
84
data interface{}
85
dataMu sync.Mutex
86
+ selfMu sync.Mutex
87
}
88
89
// NewBaseSocket creates a new default socket.
@@ -128,6 +129,8 @@ func (s *BaseSocket) Connected() bool {
128
129
// Self sends an event to this socket itself. Will be handled in the
130
// handlers HandleSelf function.
131
func (s *BaseSocket) Self(ctx context.Context, event string, data interface{}) error {
132
+ s.selfMu.Lock()
133
+ defer s.selfMu.Unlock()
134
msg := Event{T: event, SelfData: data}
135
s.engine.self(ctx, s, msg)
136
return nil
0 commit comments