Function NewWriter

pkg/streamclient/streamwriter.go:35–47

(id string, readWindow int64, dataSender DataSender)

}

func NewWriter(id string, readWindow int64, dataSender DataSender) *Writer {
	w := &Writer{
		id:           id,
		readWindow:   readWindow,
		dataSender:   dataSender,
		nextSeq:      0,
		sentNotAcked: 0,
		maxAckedSeq:  0,
		canceledChan: make(chan struct{}),
	}
	w.cond = sync.NewCond(&w.lock)
	return w
}

func (w *Writer) RecvAck(ackPk wshrpc.CommandStreamAckData) {
	w.lock.Lock()