(item workItem)
| 137 | } |
| 138 | |
| 139 | func (b *Broker) processRecvWork(item workItem) { |
| 140 | switch item.workType { |
| 141 | case "recvdata": |
| 142 | b.processRecvData(item.dataPk) |
| 143 | case "recvack": |
| 144 | b.processRecvAck(item.ackPk) |
| 145 | } |
| 146 | } |
| 147 | |
| 148 | func (b *Broker) processSendAck(ackPk wshrpc.CommandStreamAckData) { |
| 149 | b.lock.Lock() |
nothing calls this directly
no test coverage detected