Compare commits
1 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 9d74e72ede |
@@ -337,6 +337,12 @@ func (wsClient *SafeWebsocketClient) DataChannel() <-chan []byte {
|
||||
return wsClient.dataChannel
|
||||
}
|
||||
|
||||
func (wsClient *SafeWebsocketClient) WriteJSON(message any) error {
|
||||
return wsClient.mu.WriteHandler(func() error {
|
||||
return wsClient.conn.WriteJSON(message)
|
||||
})
|
||||
}
|
||||
|
||||
func (wsClient *SafeWebsocketClient) Close() error {
|
||||
wsClient.mu.WriteHandler(func() error {
|
||||
if wsClient.cancelFuncs != nil {
|
||||
|
||||
Reference in New Issue
Block a user