Method GetCanceledChan

pkg/streamclient/streamwriter.go:106–108

()

}

func (w *Writer) GetCanceledChan() <-chan struct{} {
	return w.canceledChan
}

func (w *Writer) Write(p []byte) (int, error) {
	w.lock.Lock()