Function handleMultiPart

middleware.go:151–185

(c *Client, r *Request)

}

func handleMultiPart(c *Client, r *Request) (err error) {
	var b string
	if c.multipartBoundaryFunc != nil {
		b = c.multipartBoundaryFunc()
	}

	if r.forceChunkedEncoding {
		pr, pw := io.Pipe()
		r.GetBody = func() (io.ReadCloser, error) {
			return pr, nil
		}
		w := multipart.NewWriter(pw)
		if len(b) > 0 {
			w.SetBoundary(b)
		}
		r.SetContentType(w.FormDataContentType())
		go func() {
			writeMultiPart(r, w)
			pw.Close() // close pipe writer so that pipe reader could get EOF, and stop upload
		}()
	} else {
		buf := new(bytes.Buffer)
		w := multipart.NewWriter(buf)
		if len(b) > 0 {
			w.SetBoundary(b)
		}
		writeMultiPart(r, w)
		r.GetBody = func() (io.ReadCloser, error) {
			return io.NopCloser(bytes.NewReader(buf.Bytes())), nil
		}
		r.Body = buf.Bytes()
		r.SetContentType(w.FormDataContentType())
	}
	return
}

func handleFormData(r *Request) {
	r.SetContentType(header.FormContentType)