張同樂Pytest全棧自動(dòng)化測(cè)試指南
2023-08-22 20:05 作者:bili_96857724232 | 我要投稿
// executing all writes from this goroutine.func (c *Client) writePump() {
? ?ticker := time.NewTicker(pingPeriod)
? ?defer func() {
? ? ? ?ticker.Stop()
? ? ? ?c.conn.Close()
? ?}()
? ?for {
? ? ? ?select {
? ? ? ?case message, ok := <-c.send:
? ? ? ? ? ?c.conn.SetWriteDeadline(time.Now().Add(writeWait))
? ? ? ? ? ?if !ok {
? ? ? ? ? ? ? ?// The hub closed the channel.
? ? ? ? ? ? ? ?c.conn.WriteMessage(websocket.CloseMessage, []byte{})
? ? ? ? ? ? ? ?return
? ? ? ? ? ?}
? ? ? ? ? ?w, err := c.conn.NextWriter(websocket.TextMessage)
? ? ? ? ? ?if err != nil {
? ? ? ? ? ? ? ?return
? ? ? ? ? ?}
? ? ? ? ? ?w.Write(message)
標(biāo)簽：
