Struct Writer

pkg/streamclient/streamwriter.go:16–33

}

type Writer struct {
	lock         sync.Mutex
	cond         *sync.Cond
	id           string
	dataSender   DataSender
	readWindow   int64
	nextSeq      int64
	buffer       []byte
	sentNotAcked int64
	maxAckedSeq  int64
	maxAckedRwnd int64
	finAcked     bool
	canceled     bool
	canceledChan chan struct{}
	eof          bool
	err          error
	closed       bool
}

func NewWriter(id string, readWindow int64, dataSender DataSender) *Writer {
	w := &Writer{