当该方法具有流式响应时，gRPC-Gateway通过发出换行符分隔的“块”流来处理该响应。如docs中所述。
您可以使用您的自定义封送拆收器用于特定的内容类型（例如'text/csv'）更改分隔符（默认为[]byte（'\n'））

package marshaler

import (
    "github.com/grpc-ecosystem/grpc-gateway/v2/runtime"
)

type marshaler struct {
    mime      string
    delimiter []byte
    runtime.Marshaler
}

func NewMarshaler(mime string, delimiter []byte) runtime.Marshaler {
    return &marshaler{mime: mime, delimiter: delimiter}
}

func (m *marshaler) Delimiter() []byte {
    return m.delimiter
}

func (m *marshaler) ContentType(v interface{}) string {
    return m.mime
}

然后在新的复用服务器（网关）

mux := runtime.NewServeMux(
        ....

        // allow chunked stream responses to work with "Content-Type: text/csv" requests
        runtime.WithMarshalerOption("text/csv", marshaler.NewMarshaler("text/csv", nil)),
    )

并发送具有“Content-Type：text/csv”

curl --location 'https://your-api-gateway/download' \
--header 'Content-Type: text/csv'

与你的rpc服务器无关

csvbyte := getCSV()
chunkSize := 1024 * 1024 * 1 // 1MB
    for i := 0; i < len(csvbyte); i += chunkSize {
        end := i + chunkSize
        if end > len(csvbyte) {
            end = len(csvbyte)
        }
        if err := stream.Send(&httpbody.HttpBody{
            ContentType: "text/csv",
            Data:        csvbyte[i:end],
        }); err != nil {
            return err
        }
    }