diff --git a/nats.go b/nats.go index 88f528109..73d7b802c 100644 --- a/nats.go +++ b/nats.go @@ -3113,10 +3113,7 @@ func decodeHeadersMsg(data []byte) (Header, error) { // // https://golang.org/pkg/net/textproto/#Reader.ReadMIMEHeader func readMIMEHeader(tp *textproto.Reader) (textproto.MIMEHeader, error) { - var ( - m = make(textproto.MIMEHeader) - strs []string - ) + m := make(textproto.MIMEHeader) for { kv, err := tp.ReadLine() if len(kv) == 0 { @@ -3138,16 +3135,7 @@ func readMIMEHeader(tp *textproto.Reader) (textproto.MIMEHeader, error) { i++ } value := string(kv[i:]) - vv := m[key] - if vv == nil && len(strs) > 0 { - // Single value header. - vv, strs = strs[:1:1], strs[1:] - vv[0] = value - m[key] = vv - } else { - // Multi value header. - m[key] = append(vv, value) - } + m[key] = append(m[key], value) if err != nil { return m, err }