Method SendAck

pkg/streamclient/streambroker.go:111–113

(ackPk wshrpc.CommandStreamAckData)

}

func (b *Broker) SendAck(ackPk wshrpc.CommandStreamAckData) {
	b.sendQueue.Enqueue(workItem{workType: "sendack", ackPk: ackPk})
}

func (b *Broker) SendData(dataPk wshrpc.CommandStreamData) {
	b.sendQueue.Enqueue(workItem{workType: "senddata", dataPk: dataPk})