(ctx context.Context, rw io.ReadWriter, log *zerolog.Logger)
| 89 | } |
| 90 | |
| 91 | func NewConn(ctx context.Context, rw io.ReadWriter, log *zerolog.Logger) *Conn { |
| 92 | c := &Conn{ |
| 93 | rw: rw, |
| 94 | log: log, |
| 95 | } |
| 96 | go c.pinger(ctx) |
| 97 | return c |
| 98 | } |
| 99 | |
| 100 | // Read will read messages from the websocket connection |
| 101 | func (c *Conn) Read(reader []byte) (int, error) { |