Method startAckWorkers

client/conn.go:157–163

()

}

func (c *pconn) startAckWorkers() (err error) {
	for i := 0; i < workerCount; i++ {
		c.wg.Add(1)
		go c.ackWorker()
	}
	return
}

func (c *pconn) stopAckWorkers() {
	if c.ackCh != nil {