Method sendAckLocked

pkg/streamclient/streamreader.go:132–147

(fin bool, cancel bool, errStr string)

}

func (r *Reader) sendAckLocked(fin bool, cancel bool, errStr string) {
	rwnd := r.readWindow - int64(len(r.buffer))
	if rwnd < 0 {
		rwnd = 0
	}
	ack := wshrpc.CommandStreamAckData{
		Id:     r.id,
		Seq:    r.nextSeq,
		Fin:    fin,
		Cancel: cancel,
		RWnd:   rwnd,
		Error:  errStr,
	}
	r.ackSender.SendAck(ack)
	r.lastRwndSent = rwnd
}

func (r *Reader) Read(p []byte) (int, error) {
	r.lock.Lock()