Method Write

tsunami/util/streamtolines.go:102–105

Write implements io.Writer, processing the data and calling the callback for each complete line.

(p []byte)

// Write implements io.Writer, processing the data and calling the callback for each complete line.
func (lw *LineWriter) Write(p []byte) (n int, err error) {
	streamToLines_processBuf(&lw.lineBuf, p, lw.lineFn)
	return len(p), nil
}

// Flush outputs any remaining buffered data as a final line.
// Should be called when the input stream is complete (e.g., at EOF).