代码拉取完成,页面将自动刷新
package http
import (
"compress/gzip"
"errors"
"io"
"net/http"
"strings"
)
type contentEncoder interface {
AddHeaders(*http.Header)
Encode(to io.Writer, from io.Reader) error
}
type nilEncoder struct{}
type gzipEncoder struct {
gz *gzip.Writer
}
var plainEncoder = nilEncoder{}
func getContentEncoder(name string, level int) (contentEncoder, error) {
name = strings.ToLower(name)
if name == "gzip" {
return newGZIPEncoder(level)
}
if name != "" {
return nil, errors.New("invalid content encoder")
}
return plainEncoder, nil
}
func (nilEncoder) AddHeaders(_ *http.Header) {}
func (nilEncoder) Encode(to io.Writer, from io.Reader) error {
_, err := io.Copy(to, from)
return err
}
func newGZIPEncoder(level int) (*gzipEncoder, error) {
w, err := gzip.NewWriterLevel(nil, level)
if err != nil {
return nil, err
}
return &gzipEncoder{w}, nil
}
func (e *gzipEncoder) AddHeaders(h *http.Header) {
h.Add("Content-Type", "application/json; charset=UTF-8")
h.Add("Content-Encoding", "gzip")
}
func (e *gzipEncoder) Encode(to io.Writer, from io.Reader) error {
e.gz.Reset(to)
if _, err := io.Copy(e.gz, from); err != nil {
return err
}
if err := e.gz.Flush(); err != nil {
return err
}
return nil
}
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。