fix: fixing memory leak from unbuffered channel

This commit is contained in:
2025-10-07 09:16:51 +07:00
parent 78a5b21531
commit 88ae539f54
3 changed files with 9 additions and 9 deletions

View File

@@ -155,7 +155,7 @@ func (b *SafeWebsocketClientBuilder) Build(ctx context.Context) (*SafeWebsocketC
reconnectCh: make(chan struct{}, 1),
isConnected: false,
doneMap: NewSafeMap[string, chan struct{}](),
writeChan: make(chan Message),
writeChan: make(chan Message, 1),
}
if b.authenticateFn != nil {
@@ -425,7 +425,7 @@ func (wsClient *SafeWebsocketClient) reconnectHandler() {
}
func (wsClient *SafeWebsocketClient) ReconnectChannel() <-chan struct{} {
reconnectCh := make(chan struct{})
reconnectCh := make(chan struct{}, 1)
wsClient.mu.WriteHandler(func() error {
wsClient.reconnectChans = append(wsClient.reconnectChans, reconnectCh)
return nil