Function NewStreamWriter

pkg/coder/engine/engine.go:261–263

NewStreamWriter creates a StreamWriter that calls onOutput for each line.

(onOutput func(string))

// NewStreamWriter creates a StreamWriter that calls onOutput for each line.
func NewStreamWriter(onOutput func(string)) *StreamWriter {
	return &StreamWriter{onOutput: onOutput}
}

func (sw *StreamWriter) Write(p []byte) (int, error) {
	sw.mu.Lock()