``` go

func (c *client) write() {

defer func() {

g.Dump("write quit:" + gconv.String(c.Unique))

}()

for {

select {

case <-c.Ctx.Done():

goto ERR

case msg := <-c.writeCh:

err := c.conn.WriteMessage(websocket.TextMessage, msg)

atomic.AddInt64(&c.WriteChNum, -1)

if err != nil {

fmt.Println(msg)

g.Log().Cat("write-err").Info(c.Ctx, msg)

goto ERR

}

}

}

ERR:

Manager().ClientCancel(c.Ctx, c.Unique)

return

}

```

写数据的时候 走到了 <-c.Ctx.Done()