Method Write

pkg/waveapp/streamingresp.go:77–117

(data []byte)

}

func (w *StreamingResponseWriter) Write(data []byte) (int, error) {
	if !w.headerSent {
		w.WriteHeader(http.StatusOK)
	}

	originalLen := len(data)

	// If we already have data in the buffer
	if w.buffer.Len() > 0 {
		// Fill the buffer up to maxChunkSize
		spaceInBuffer := maxChunkSize - w.buffer.Len()
		if spaceInBuffer > 0 {
			// How much of the new data can fit in the buffer
			toBuffer := spaceInBuffer
			if toBuffer > len(data) {
				toBuffer = len(data)
			}
			w.buffer.Write(data[:toBuffer])
			data = data[toBuffer:] // Advance data slice
		}

		// If buffer is full, send it
		if w.buffer.Len() == maxChunkSize {
			w.sendChunk(w.buffer.Bytes())
			w.buffer.Reset()
		}
	}

	// Send any full chunks from data
	for len(data) >= maxChunkSize {
		w.sendChunk(data[:maxChunkSize])
		data = data[maxChunkSize:]
	}

	// Buffer any remaining data
	if len(data) > 0 {
		w.buffer.Write(data)
	}

	return originalLen, nil
}

func (w *StreamingResponseWriter) Close() error {
	if !w.headerSent {