Skip to content

Commit

Permalink
expose Upgrade
Browse files Browse the repository at this point in the history
  • Loading branch information
liuyuesong committed Jul 8, 2022
1 parent adf9716 commit c7a8a29
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions xwebsocket/ws.go
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@ import (

// WS websocket 适配器
type WS struct {
upgrader websocket.Upgrader
Upgrader websocket.Upgrader
session map[string]*Conn
sessionMu sync.RWMutex
receive chan *reqMessage
Expand All @@ -28,7 +28,7 @@ var _ cs.ServerAdapter = &WS{}
// New 实例化 websocket 适配器
func New() *WS {
return &WS{
upgrader: websocket.Upgrader{
Upgrader: websocket.Upgrader{
ReadBufferSize: 1024,
WriteBufferSize: 1024,
},
Expand All @@ -44,7 +44,7 @@ func (ws *WS) Srv() *cs.Srv {

// Handler impl http.HandlerFunc to upgrade to websocket protocol
func (ws *WS) Handler(w http.ResponseWriter, req *http.Request) {
conn, err := ws.upgrader.Upgrade(w, req, nil)
conn, err := ws.Upgrader.Upgrade(w, req, nil)
if err != nil {
return
}
Expand Down

0 comments on commit c7a8a29

Please sign in to comment.