...
1
2
3
4 package websocket
5
6 import (
7 "net"
8
9 "nhooyr.io/websocket/internal/util"
10 )
11
12 func (c *Conn) RecordBytesWritten() *int {
13 var bytesWritten int
14 c.bw.Reset(util.WriterFunc(func(p []byte) (int, error) {
15 bytesWritten += len(p)
16 return c.rwc.Write(p)
17 }))
18 return &bytesWritten
19 }
20
21 func (c *Conn) RecordBytesRead() *int {
22 var bytesRead int
23 c.br.Reset(util.ReaderFunc(func(p []byte) (int, error) {
24 n, err := c.rwc.Read(p)
25 bytesRead += n
26 return n, err
27 }))
28 return &bytesRead
29 }
30
31 var ErrClosed = net.ErrClosed
32
33 var ExportedDial = dial
34 var SecWebSocketAccept = secWebSocketAccept
35 var SecWebSocketKey = secWebSocketKey
36 var VerifyServerResponse = verifyServerResponse
37
38 var CompressionModeOpts = CompressionMode.opts
39
View as plain text