LumeWeb
/
libs5-go
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

refactor: use lowercase socket

This commit is contained in:
Derrick Hammer 2024-01-07 06:47:19 -05:00
parent 2e9b07c6bd
commit 0028483817
Signed by: pcfreak30
GPG Key ID: C997C339BE476FF2
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
net/ws.go
View File

@ -15,7 +15,7 @@ var (
type WebSocketPeer struct { type WebSocketPeer struct {
BasePeer BasePeer
Socket *websocket.Conn socket *websocket.Conn
} }
func (p *WebSocketPeer) Connect(uri *url.URL) (interface{}, error) { func (p *WebSocketPeer) Connect(uri *url.URL) (interface{}, error) {
@ -33,14 +33,14 @@ func (p *WebSocketPeer) NewPeer(options *TransportPeerConfig) (Peer, error) {
connectionURIs: options.Uris, connectionURIs: options.Uris,
socket: options.Socket, socket: options.Socket,
}, },
Socket: options.Socket.(*websocket.Conn), socket: options.Socket.(*websocket.Conn),
} }
return peer, nil return peer, nil
} }
func (p *WebSocketPeer) SendMessage(message []byte) error { func (p *WebSocketPeer) SendMessage(message []byte) error {
err := p.Socket.Write(context.Background(), websocket.MessageBinary, message) err := p.socket.Write(context.Background(), websocket.MessageBinary, message)
if err != nil { if err != nil {
return err return err
} }
@ -54,7 +54,7 @@ func (p *WebSocketPeer) RenderLocationURI() string {
func (p *WebSocketPeer) ListenForMessages(callback EventCallback, options ListenerOptions) { func (p *WebSocketPeer) ListenForMessages(callback EventCallback, options ListenerOptions) {
for { for {
_, message, err := p.Socket.Read(context.Background()) _, message, err := p.socket.Read(context.Background())
if err != nil { if err != nil {
if options.OnError != nil { if options.OnError != nil {
(*options.OnError)(err) (*options.OnError)(err)
@ -76,7 +76,7 @@ func (p *WebSocketPeer) ListenForMessages(callback EventCallback, options Listen
} }
func (p *WebSocketPeer) End() error { func (p *WebSocketPeer) End() error {
err := p.Socket.Close(websocket.StatusNormalClosure, "") err := p.socket.Close(websocket.StatusNormalClosure, "")
if err != nil { if err != nil {
return err return err
} }