Method CloseWithError

pkg/streamclient/streamwriter.go:176–207

If CloseWithError() is called while a Write is blocked, the Write will return an error and buffered data may be discarded.

(err error)

// If CloseWithError() is called while a Write is blocked, the Write will return an error and buffered data may be discarded.
func (w *Writer) CloseWithError(err error) error {
	w.lock.Lock()
	defer w.lock.Unlock()

	if w.closed {
		return nil
	}

	w.closed = true
	if w.err == nil {
		w.err = io.ErrClosedPipe
	}
	w.cond.Broadcast()

	var dataPk wshrpc.CommandStreamData
	if err == nil || err == io.EOF {
		dataPk = wshrpc.CommandStreamData{
			Id:  w.id,
			Seq: w.nextSeq,
			Eof: true,
		}
	} else {
		dataPk = wshrpc.CommandStreamData{
			Id:    w.id,
			Seq:   w.nextSeq,
			Error: err.Error(),
		}
	}
	w.dataSender.SendData(dataPk)

	return nil
}