Method StreamHandler

pkg/groq/response.go:48–64

()

}

func (r *ReadWriter) StreamHandler() {
	defer r.r.Body.Close()
	r.setResponseHeader()
	buf := make([]byte, 4*1024)
	for {
		n, err := r.r.Body.Read(buf)
		if err != nil {
			if err == io.EOF {
				return
			}
		}
		if n == 0 {
			continue
		}
		r.w.Write(buf[:n])
	}
}