Method writeMultipartBody

executor/http_executor.go:177–190

(bodyWriter *io.PipeWriter, parameters []ExecutionParameter, cancel context.CancelCauseFunc)

}

func (e HttpExecutor) writeMultipartBody(bodyWriter *io.PipeWriter, parameters []ExecutionParameter, cancel context.CancelCauseFunc) (string, int64) {
	multipartSize := e.calculateMultipartSize(parameters)
	formWriter := multipart.NewWriter(bodyWriter)
	go func() {
		defer func() { _ = bodyWriter.Close() }()
		defer func() { _ = formWriter.Close() }()
		err := e.writeMultipartForm(formWriter, parameters)
		if err != nil {
			cancel(err)
			return
		}
	}()
	return formWriter.FormDataContentType(), multipartSize
}

func (e HttpExecutor) writeInputBody(bodyWriter *io.PipeWriter, input stream.Stream, cancel context.CancelCauseFunc) {
	go func() {