Struct Reader

pkg/streamclient/streamreader.go:17–30

}

type Reader struct {
	lock         sync.Mutex
	cond         *sync.Cond
	id           string
	ackSender    AckSender
	readWindow   int64
	nextSeq      int64
	buffer       []byte
	eof          bool
	err          error
	closed       bool
	lastRwndSent int64
	oooPackets   []wshrpc.CommandStreamData // out-of-order packets awaiting delivery
}

func NewReader(id string, readWindow int64, ackSender AckSender) *Reader {
	return NewReaderWithSeq(id, readWindow, 0, ackSender)