Feature Description
The WebSocket read function does not support the binary event type.
Additional Context (optional)
No response
Code Snippet (optional)
func (kws *Websocket) read(ctx context.Context) {
timeoutTicker := time.NewTicker(ReadTimeout)
defer timeoutTicker.Stop()
for {
select {
case <-timeoutTicker.C:
if !kws.hasConn() {
continue
}
kws.mu.RLock()
mType, msg, err := kws.Conn.ReadMessage()
kws.mu.RUnlock()
if mType == PingMessage {
kws.fireEvent(EventPing, nil, nil)
continue
}
if mType == PongMessage {
kws.fireEvent(EventPong, nil, nil)
continue
}
if mType == CloseMessage {
kws.disconnected(nil)
return
}
if err != nil {
kws.disconnected(err)
return
}
if mType == BinaryMessage {
kws.fireEvent(EventBinary, msg, nil)
continue
}
// We have a message and we fire the message event
kws.fireEvent(EventMessage, msg, nil)
case <-ctx.Done():
return
}
}
}Checklist:
Feature Description
The WebSocket read function does not support the binary event type.
Additional Context (optional)
No response
Code Snippet (optional)
Checklist: